Hi,
Is it possible to passthrough null values (KTable) even if no internal state for such key?
Right now, the Kafka streams application optimizes it.
Best,
Stanislav
Hi,
Is it possible to passthrough null values (KTable) even if no internal state for such key?
Right now, the Kafka streams application optimizes it.
Best,
Stanislav
Not 100% sure, but I believe if you would disable caching it might pass through all records?
Not sure what your overall application looks like, but using a manual process()
(or transform()
in older versions) would also allow you to do this – but not sure if this would fix into your overall application code.
You could also read the data as KStream
, and do a “broadcast” and later merge…? Something like this:
KStream input = ...
KStreams nullStream = input.filter(/*only keep nulls*/);
KStream tableStream = input.toTable(...).toStream();
KStream merged = tableStream.merge(nullStream);
“broadcast” and later merge
Nice idea. I will try.
Thank you!