AKHQ 是一个 Kafka 集群管理工具,state 和 coordinator 列都是针对 Kafka 中的消费者组(consumer group)而言的。
state 列展示的是消费者组的状态,包括 "Stable"(稳定) "Preparing Rebalance"(准备重平衡)等等。若状态为 "Preparing Rebalance" 则说明有新的消费者或消费者主题分区发生了变化,需要进行重平衡操作。
coordinator 列则展示的是消费者组的协调器信息,包括内网地址、端口号以及节点等信息。可以通过以下代码示例获取消费者组的状态和协调器信息:
Properties props = new Properties();
props.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
AdminClient adminClient = AdminClient.create(props);
ConsumerGroupDescription description = adminClient.describeConsumerGroups(Arrays.asList("test-group")).all().get().get("test-group");
String state = description.state().toString();
String coordinator = description.coordinator().toString();
System.out.println("消费者组状态:" + state);
System.out.println("协调器信息:" + coordinator);
adminClient.close();
上一篇:AKHQ中的数据遮蔽
下一篇:AKHQ中描述主题偏移错误的错误