步骤四：消费消息
更新时间：2026-02-04 01:37:16
PDF
-
通过 VNC 登录 Kafka 客户端节点。详情参考通过 VNC 登录 Kafka。
-
在客户端节点执行以下命令行，消费 Topic 的消息。
cd /opt/kafka/current/bin ./kafka-console-consumer.sh --bootstrap-server <连接地址> --topic <Topic 名称> --from-beginning-
参数说明
参数 说明 连接地址
可在 Kafka 集群详情页面，查看连接地址。
Topic 名称
目标 Topic 名称，需根据实际情况进行填写。
--from-beginning
表示从最新的开始消费。
-
命令行示例
$ cd /opt/kafka/current/bin ./kafka-console-consumer.sh --bootstrap-server 192.168.0.1:9092,192.168.0.2:9092,192.168.0.3:9092 --topic test --from-beginning hi hello world how are you
-
-
在客户端节点执行以下命令行，可查看
testTopic 的消息分布情况。$ cd /opt/kafka/current/bin ./kafka-topics.sh --describe --zookeeper 192.168.0.6:2181,192.168.0.8:2181,192.168.0.7:2181/kafka/cl-zom1un35 --topic test Topic:test PartitionCount:3 ReplicationFactor:1 Configs: Topic: test Partition: 0 Leader: -1 Replicas: 1 Isr: 1 Topic: test Partition: 1 Leader: -1 Replicas: 2 Isr: 2 Topic: test Partition: 2 Leader: 3 Replicas: 3 Isr: 3 -
在客户端节点执行以下命令行，查看消费者消费情况。
-
kafka 0.9.0.0 以后的版本使用
kafka-consumer-groups.sh查看消费者消费情况。$ cd /opt/kafka/current/bin ./kafka-consumer-groups.sh --bootstrap-server 192.168.0.3:9092,192.168.0.4:9092,192.168.0.9:9092 --describe --group my-group Note: This will not show information about old Zookeeper-based consumers. TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID test 0 10 10 0 consumer-1-0000f0c2-eee7-432b-833b-c882334c8f71 /192.168.100.26 consumer-1 test 1 7 7 0 consumer-1-0000f0c2-eee7-432b-833b-c882334c8f71 /192.168.100.26 consumer-1 -
kafka 0.9.0.0 以前的版本使用
kafka-consumer-offset-checker.sh查看消费者消费情况。$ cd /opt/kafka/current/bin ./kafka-consumer-offset-checker.sh --zookeeper 192.168.0.6:2181,192.168.0.8:2181,192.168.0.7:2181/kafka/cl-zom1un35 --topic test --group my-group
-