我试图限制kafka主题的日志大小 .
我按照 kafka documentation(Kafka 0.10.0 Documentation) 设置了这两个属性 cleanup.policy=delete,retention.bytes=1.
-
主题描述命令的结果
./kafka-topics.sh --describe --zookeeper localhost：2181 --topic kafkatest1主题：kafkatest1 PartitionCount：3 ReplicationFactor：1配置：cleanup.policy = delete，retention.bytes = 1
我期待无论我写给主题'kafkatest1'的任何消息都会被自动删除，因为我已将retention.bytes设置为1.但是消息会不断被追加 .
是否需要任何其他配置才能实现此目的？
1 回答
请检查
log.segment.bytes（默认值为1073741824字节） . 据我所知，在滚动日志段时会考虑保留 .你能解释一下你想要实现的目标吗？为什么要发送邮件来删除它？