我在一个有3个节点的集群中使用Kafka 0.10.0.0
我在经纪人和所有经纪人上启用了自动主题创建，我已添加了指定分区和副本数量的属性
num.partitions=2
default.replication.factor=2
现在，当我通过命令行查询主题描述时，我得到了意想不到的结果 . 有时它为此主题显示1个分区，有时为此主题显示2个分区 .
bin/kafka-topics.sh --describe --zookeeper IP1:2181,IP2:2181,IP3:2181 --topic T.topic1_
Topic:T.topic1 PartitionCount:1 ReplicationFactor:2 Configs:
Topic: T.topic1 Partition: 0 Leader: 2 Replicas: 2,3 Isr: 2
bin/kafka-topics.sh --describe --zookeeper IP1:2181,IP2:2181,IP3:2181 --topic T.topic1
Topic:T.topic1 PartitionCount:2 ReplicationFactor:2 Configs:
Topic: T.topic1 Partition: 0 Leader: 3 Replicas: 3,0 Isr: 0,3
Topic: T.topic1 Partition: 1 Leader: 0 Replicas: 0,2 Isr: 2,0
我错误地查询，因为它显示1分区显示副本2但ISR只有1
此外，此主题的使用者组始终显示消费者正在侦听2个分区bin / kafka-consumer-groups.sh --new-consumer --bootstrap-server IP1：9092，IP2：9092，IP3：9092 - describe --group Group1
GROUP TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG OWNER
Group1 topic1 0 5 5 0 consumer-58_/10.20.1.20
Group1 topic1 1 3 3 0 consumer-58_/10.20.1.20
另外，指定我的代理配置： - zookeeper.properties
zookeeper.server=IP1:2181,IP2:2181,IP3:2181 (not sure need to give all ZK servers)
- server.properties
num.partitions=2
default.replication.factor=2
zookeeper.connect=IP1:2181,IP2:2181,IP3:2181
注意：Zookeeper和Kafka正在所有IP1，IP2，IP3服务器上运行