Hi - in Samza 0.8.0 it seems that the Kafka topic created for a key-value
store changelog does not have compaction enabled, as described in this jira:

https://issues.apache.org/jira/browse/SAMZA-226

If Samza creates this changelog topic, am I correct that we then later need
to run something like this to enable compaction (and smaller segment size)?

bin/kafka-topics.sh --zookeeper whatever:2181/kafka --topic
"the-changelog-topic" --alter --config cleanup.policy=compact --config
segment.bytes=1000000

Thanks,
Zach

Reply via email to