在 Kafka 中，生产者和消费者的命令行工具分别是 kafka-console-producer 和 kafka-console-consumer。这两个工具允许你通过命令行界面进行消息的生产和消费。以下是它们的基本用法：
生产者命令行工具 (kafka-console-producer):
kafka-console-producer.sh --bootstrap-server <broker(s)> --topic <topic>
<broker(s)>：Kafka 集群的 broker 地址和端口，例如localhost:9092。<topic>：生产者要发送消息到的主题。
示例：
kafka-console-producer.sh --bootstrap-server localhost:9092 --topic my_topic
此命令会打开一个控制台，你可以在其中输入消息，并将其发送到指定的主题。
消费者命令行工具 (kafka-console-consumer):
kafka-console-consumer.sh --bootstrap-server <broker(s)> --topic <topic> [--group <group_id>]
<broker(s)>：Kafka 集群的 broker 地址和端口，例如localhost:9092。<topic>：消费者要订阅的主题。[--group <group_id>]：可选，消费者组的标识符。
示例：
kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my_topic
此命令将订阅指定主题的消息并在控制台上显示。
请注意，这些命令行工具的参数可能会因 Kafka 版本的不同而有所变化，确保查看相应版本的官方文档以获取准确的命令行参数。
Was this helpful?
0 / 0