2016-08-23 91 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是的,我認爲這是正確的。 –