Kafka主题描述没有给出一致的结果

9njqaruj  于 2021-06-08  发布在  Kafka
关注(0)|答案(0)|浏览(197)

我在一个有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服务器上运行

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题