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
