Hi,

I am curious about the relationship of KTables and state store in Kafka
Streams. When I create a table with the `table` method, it uses the
original topic as a changelog, thus persisting a table changelog does not
make much sense. When I create invoke `countByKey` on a KStream, the result
is a KTable and I find a changelog topic for it created. Thus Kafka Streams
can recreate the state store. When I join two tables, this will also result
in a new KTable, but this time, there is no changelog topic created.

This is a little bit confusing. Does the `table` method read the whole
original topic as an input again after a restart, or how does it load the
whole table again? Can someone explain the rules to persist or restore a
KTable to or from a changelog?

Best regards
Jan

Reply via email to