2016-08-23 34 views
2

工作,我尝试用下面的命令日志保留字节不与卡夫卡

bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic app.test.client --config retention.bytes=10485760

做一个

bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topic 
app.test.client 
Topic:app.test.client PartitionCount:3  ReplicationFactor:2  Configs:retention.bytes=10485760 
    Topic: app.test.client Partition: 0 Leader: 2  Replicas: 2,1 Isr: 2,1 
    Topic: app.test.client Partition: 1 Leader: 0  Replicas: 0,2 Isr: 0,2 
    Topic: app.test.client Partition: 2 Leader: 1  Replicas: 1,0 Isr: 1,0 
验证的配置设置设定每个主题的log.retention.bytes

我将保留字节设置为10MB - > 10485760.但是,即使在10MB之后,我的日志文件也在增长。

$du -hs /mnt/kafka/logs/* 
128M /mnt/kafka/logs/app.test.client-1 
128M /mnt/kafka/logs/app.test.client-2 

版本 卡夫卡 - 0.8.2.1

如何正确设置每个主题此设置?

回答

1

我认为log.retention.bytes不会对主题/分区大小施加硬性限制,而是向Kafka发出何时删除超过您设置此属性值的最早的段文件的信号。

+2

由于默认段大小为5G,因此在一个分区至少有5G数据之前,不会有删除段需要删除。 – Kazaag

+0

@Kazaag是的,我认为这是正确的。 –