开发喵星球

在 Kafka 中，生产者和消费者的命令行工具分别是 kafka-console-producer 和 kafka-console-consumer。这两个工具允许你通过命令行界面进行消息的生产和消费。以下是它们的基本用法：

生产者命令行工具 (kafka-console-producer):

kafka-console-producer.sh --bootstrap-server  --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  --topic  [--group ]

• <broker(s)>：Kafka 集群的 broker 地址和端口，例如 localhost:9092。
• <topic>：消费者要订阅的主题。
• [--group <group_id>]：可选，消费者组的标识符。

示例：

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my_topic

此命令将订阅指定主题的消息并在控制台上显示。

请注意，这些命令行工具的参数可能会因 Kafka 版本的不同而有所变化，确保查看相应版本的官方文档以获取准确的命令行参数。