2016-11-10 90 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

谢谢...我得到了我的解决方案... –