我在一个有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--新使用者--引导服务器ip1:9092、ip2:9092、ip3:9092--描述--组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)
--服务器属性
num.partitions=2
default.replication.factor=2
zookeeper.connect=IP1:2181,IP2:2181,IP3:2181
注意:zookeeper和kafka在所有ip1、ip2、ip3服务器上运行
暂无答案!
目前还没有任何答案,快来回答吧!