Hi,

I noticed the following:
When a kafka streams application starts, it will restore its state in its
state-stores (from the log-compacted kafka topic).  All good so far, but I
noticed that the 'deleted' entries are actually read in into the store as
'key' with value:`null`

Is this expected behaviour?  I would assume that 'null' values are ignored
when restoring the state as this is exactly how the entries are deleted on
the log-compacted kafka-topic.

When the compaction has run on the kafka topic, all is fine, but when the
segment is not compacted yet, these null values are read in.

Greets,
Bart

Reply via email to