Hi,

in the documentation for KTable#through, it is stated that a new changelog
topic will be created for the table. It also states that calling through is
equivalent to calling #to followed by KStreamBuilder#table.

http://kafka.apache.org/0101/javadoc/org/apache/kafka/streams/kstream/KTable.html#through(org.apache.kafka.common.serialization.Serde,%20org.apache.kafka.common.serialization.Serde,%20java.lang.String,%20java.lang.String)

In the docs for KStreamBuilder#table it is stated that no new changelog
topic will be created since the underlying topic acts as the changelog.
I've verified that this is the case.

Is there another API method to materialize the results of a KTable
including a changelog, i.e. such that kafka streams creates the topic and
uses the naming schema for changelog topics? The use case I have in mind is
aggregate followed by mapValues.

Best,
Mikael

Reply via email to