限制Kafka中特定主题的日志大小

8yoxcaq7 于 2021-06-08 发布在 Kafka

关注(0)|答案(1)|浏览(363)

我试图限制Kafka主题的日志大小。
我遵循kafka文档（kafka 0.10.0文档）并将这两个属性cleanup.policy=delete，retention.bytes=1。
-->主题描述命令的结果
./kafka-topics.sh—描述—Zookeeperlocalhost:2181 --topic Kafka特1topic:kafkatest1 partitioncount:3
复制ionfactor:1
configs:cleanup.policy=delete，retention.bytes=1
因为我已经将retention.bytes设置为1，所以我希望我写的主题为“kafkatest1”的任何消息都会被自动删除。但信息不断被附加。
是否需要其他配置来实现这一点？

apache-kafka

来源：https://stackoverflow.com/questions/38786794/limiting-log-size-for-a-particular-topic-in-kafka