在kafka中,我使用./kafka-topics.sh命令创建了主题。命令是这样的
./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 8 --topic test
主题测试有8个分区,有 server.properties
Kafka代理中的配置 num.partitions
默认参数为1。
现在我的具体问题是它不会在主题测试的分区中产生歧义。它将考虑在创建主题或 num.partition
在 server.properties
1条答案
按热度按时间58wvjzkj1#
Kafka可以配置为按需创建主题。这意味着,如果您尝试向不存在的主题发送消息,则将自动创建主题,其中的分区数指定为
num.partitions
中的属性server.properties
. 如果你想自己用将使用指定为的分区数创建主题
--partitions
,在你的情况下是8,和财产num.partitions
将被忽略。