管理学习网站,最早做美食团购的网站,网站应用市场设计,网站建设苏州1. 确保 Kafka 服务运行
先检查 Kafka 和 Zookeeper 是否正在运行#xff1a;
systemctl status kafka
systemctl status zookeeper
如果没有启动#xff0c;先启动服务#xff1a;
systemctl start zookeeper
systemctl start kafka 2. 进入 Kafka 安装目录
通常 …1. 确保 Kafka 服务运行
先检查 Kafka 和 Zookeeper 是否正在运行
systemctl status kafka
systemctl status zookeeper
如果没有启动先启动服务
systemctl start zookeeper
systemctl start kafka 2. 进入 Kafka 安装目录
通常 Kafka 的脚本文件位于 Kafka 的安装目录比如 /opt/kafka/bin 或 /usr/local/kafka/bin。切换到该目录
cd /opt/kafka/bin 3. 列出现有的 Topics
使用 kafka-topics.sh 列出当前的 topics
./kafka-topics.sh --bootstrap-server localhost:9092 --list
你会看到所有可用的 topics。 4. 查看 Topic 数据
使用 kafka-console-consumer.sh 来消费指定 topic 的数据。
命令
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic-name --from-beginning
替换 topic-name 为你想要查看的 topic 名字。--from-beginning 表示从头开始消费所有消息。如果你想查看最新的数据可以省略这个参数。 示例
假设 Kafka 安装在 /opt/kafka要查看名为 test-topic 的数据
cd /opt/kafka/bin ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test-topic --from-beginning 5. 其他常用参数 指定消费组 ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic-name --group group-name 替换 group-name 为消费组名称。 只查看部分消息 如果消息量很大你可以控制只读取有限条消息比如 10 条 ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic topic-name --max-messages 10
