2016-11-10 132 views
2

在kafka中,我使用./kafka-topics.sh命令創建了主題。該命令會像server.properties中的分區數量和主題創建中的歧義 - apache kafka中的分區參數

./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 8 --topic test 

隨着話題測試8個分區,有在卡夫卡的經紀人,也有num.partitions參數是默認值爲1

現在我的具體問題是,server.properties配置不會在主題測試的分區中造成歧義。它會考慮在創建主題時提及的分區或num.partition中的server.properties

回答

0

可以配置Kafka以根據需要創建主題。這意味着如果您嘗試將消息發送到不存在的主題,則會自動創建主題,其中server.properties中指定爲num.partitions屬性的分區數量將自動創建。如果你打算自行創建主題使用

./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 8 --topic test 

的話題將與指定爲--partitions分區的數量來創建,你的情況這將是8,和財產num.partitions將被忽略。

+0

謝謝...我得到了我的解決方案... –