限制kafka中特定主題的日誌大小

我跟着kafka文檔（卡夫卡0.10.0文檔）並設置這兩個屬性cleanup.policy = delete，retention.bytes = 1。

- >主題的結果描述命令

./kafka-topics.sh --describe --zookeeper本地主機：2181 --topic kafkatest1主題：kafkatest1 PartitionCount：3
ReplicationFactor： 1個
CONFIGS：cleanup.policy =刪除，retention.bytes = 1

我期待，無論消息我寫主題「kafkatest1」將自動被刪除，因爲我已經設置retention.bytes設置爲1. 但消息不斷追加。

是否有任何額外的配置需要實現？

來源

2016-08-05 Deepak Kumar

請檢查您的log.segment.bytes（默認爲1073741824字節）。據我所知，當日志段被滾動時，保留將被考慮在內。

你能解釋一下你想達到的目標嗎？爲什麼發送消息來刪除它？

來源

2016-08-05 10:35:09 TobiSH

我試着將'segment.bytes'改爲15個字節。但仍然沒有成功。我試圖限制每個主題basis.so相同的kafka羣集可以在多個用戶之間共享的大小。我保留'retention.bytes = 1'，以便我可以使用控制檯消費者本身驗證此功能。 –

這有沒有影響？ – TobiSH

限制kafka中特定主題的日誌大小

回答

相關問題