According to the below links I'm supposed to be able to set the retention.policy
value to "compact,delete"
.
https://issues.apache.org/jira/browse/KAFKA-4015
https://cwiki.apache.org/confluence/display/KAFKA/KIP-71%3A+Enable+log+compaction+and+deletion+to+co-exist
However when I try to alter the retention policy by running:
./kafka-configs.sh --zookeeper $KAFKAZKHOSTS --entity-type
topics --alter --add-config cleanup.policy=compact,delete --entity-name topicname
I'm getting the following error:
requirement failed: Invalid entity config: all configs to be added must be in the format "key=val".
--add-config cleanup.policy=[compact,delete]
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With