Kafka 命令行工具：查询消息完全指南

Kafka 提供了强大的命令行工具集，用于与 Kafka 集群交互和查询消息。本文将介绍一些常用的 Kafka 命令行工具，并提供实际示例以帮助您入门。

1. 使用 kafka-console-consumer 读取消息

kafka-console-consumer 工具允许您从 Kafka 主题中读取消息。

示例： 从名为 'test' 的主题读取消息，从最早的可用消息开始：

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

2. 使用 kafka-console-producer 发送消息

kafka-console-producer 工具允许您向 Kafka 主题发送消息。

示例： 向名为 'test' 的主题发送消息：

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

输入消息并按 Enter 键发送。

3. 使用 kafka-consumer-groups 管理消费者组

kafka-consumer-groups 工具允许您管理和监控消费者组。

示例： 查看名为 'test-group' 的消费者组的消费情况：

bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group test-group

4. 使用 kafka-topics 管理主题

kafka-topics 工具允许您管理 Kafka 主题。

示例： 列出所有主题：

bin/kafka-topics.sh --bootstrap-server localhost:9092 --list

5. 使用 kafka-run-class 执行 Kafka 类

kafka-run-class 工具允许您执行任意的 Kafka 类。

示例： 查看名为 'test' 的主题中最新的 10 条消息：

bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic test --time -1 --offsets 10

总结

本文介绍了一些常用的 Kafka 命令行工具，用于查询和管理 Kafka 消息。 这些工具提供了强大的功能，可以帮助您调试、监控和操作 Kafka 集群。 有关每个工具的更多详细信息和选项，请参阅 Kafka 官方文档。