kafka log.retention.hours在多個經紀人中的不一致性

Question

我試圖運行多個kafka經紀人。有一個名爲server.properties的文件，在我的server.properties文件中有一個字段「log.retention.hours」，它被設置爲168。現在，如果我更改kafka代理屬性文件並在每個屬性文件中設置「log.retention.hours」的不同值，那麼它將如何在分佈式環境中執行操作。我的意思是說單個集羣中的卡夫卡經紀人複製所有分區，如果broker-1中的log.retention.hours與broker-2中的log.retention.hours不同，會發生什麼情況。如何複製分區將發生。 （server-1 log.retention.period）<（server-2 log.retention.period））將再次從其他代理複製服務器-1中已刪除的數據。

Answer 1

卡夫卡設計的基本假設之一是，除了極少數例外（例如端口），集羣中的經紀人具有與in this Kafka Improvement Proposal所述相同的配置。因此，應避免您在問題中描述的配置不一致的情況。