根据以下链接,我应该能够将retention.policy
值设置为"compact,delete"
.
https://issues.apache.org/jira/browse/KAFKA-4015
但是,当我尝试通过运行来更改保留策略时:
./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]
归档时间: |
|
查看次数: |
2735 次 |
最近记录: |