Yes, that is correct.
-Matthias On 2/7/17 6:39 PM, Mathieu Fenniak wrote: > Hey kafka users, > > Is it correct that a Kafka topic that is used for a KTable should be set to > cleanup.policy=compact? > > I've never noticed until today that the KStreamBuilder#table() > documentation says: "However, no internal changelog topic is created since > the original input topic can be used for recovery"... [1], which seems like > it is only true if the topic is configured for compaction. Otherwise the > original input topic won't necessarily contain the data necessary for > recovery of the state store. > > [1] > https://github.com/apache/kafka/blob/e108a8b4ed4512b021f9326cf079517523c83060/streams/src/main/java/org/apache/kafka/streams/kstream/KStreamBuilder.java#L355 > > Thanks, > > Mathieu >
signature.asc
Description: OpenPGP digital signature
