无法将 Kafka 保留策略设置为压缩和删除

emi*_*ini 2 apache-kafka

根据以下链接,我应该能够将retention.policy值设置为"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

但是,当我尝试通过运行来更改保留策略时:

./kafka-configs.sh --zookeeper $KAFKAZKHOSTS  --entity-type
 topics --alter --add-config cleanup.policy=compact,delete --entity-name topicname
Run Code Online (Sandbox Code Playgroud)

我收到以下错误:

requirement failed: Invalid entity config: all configs to be added must be in the format "key=val".
Run Code Online (Sandbox Code Playgroud)

小智 8

--add-config cleanup.policy=[compact,delete]

  • 虽然您所写的内容可能会回答问题,但它似乎确实缺乏解释,并且可能会引起其他用户的非法混淆。您能否扩展您的答案,使其更清晰、更易于理解?这将提供更好的答案,并帮助未来的用户了解问题是如何解决的。 (3认同)