在Kafka中,查看所有主题及其分区偏移量的常用命令是使用 kafka-topics.sh
脚本,它是Kafka安装的一部分。您可以使用以下命令来查看所有主题的详情:
shellkafka-topics.sh --bootstrap-server <server-address> --list
这个命令将显示Kafka集群中的所有主题。这里的 <server-address>
是Kafka代理的地址,格式通常是 hostname:port
。
为了查看特定主题的分区及其当前偏移量,可以使用 kafka-consumer-groups.sh
工具。首先,您需要知道消费者群组的名称,然后可以运行:
shellkafka-consumer-groups.sh --bootstrap-server <server-address> --group <group-name> --describe
这个命令会展示指定消费者群组消费的主题的分区信息及其偏移量。这里的 <group-name>
是指消费者群组的名字。
例如,假如您运行一个Kafka集群在本地机器(localhost)上,端口为9092,并且有一个名为"test-group"的消费者群组。那么,您可以使用如下命令来查看这个群组所消费主题的详细信息:
shellkafka-consumer-groups.sh --bootstrap-server localhost:9092 --group test-group --describe
这将列出“test-group”正在消费的所有主题的分区和偏移量等详细信息。
以上就是查看Kafka中所有主题及其分区偏移量的步骤。
2024年7月24日 09:49 回复