Passthrough null values

Stream Processing Kafka Streams
1

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

2

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);
3

“broadcast” and later merge

Nice idea. I will try.

Thank you!