温馨提示×

kafka命令行消费如何启动

小樊
81
2024-12-18 18:14:24
栏目: 大数据

要启动Kafka命令行消费者,请按照以下步骤操作:

  1. 首先,确保已经安装了Apache Kafka。如果尚未安装,请访问官方网站(https://kafka.apache.org/downloads)下载并安装适合您操作系统的版本。

  2. 创建一个Kafka消费者组。在命令行中,使用以下命令创建一个新的消费者组(将your-group-id替换为您选择的消费者组ID):

bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --create --group your-group-id
  1. 使用以下命令启动Kafka消费者(将your-topic替换为您要订阅的主题名称,将your-group-id替换为您在第2步中创建的消费者组ID):
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic your-topic --from-beginning --group your-group-id

现在,您已经成功启动了一个Kafka命令行消费者。它将连接到本地Kafka服务器(localhost:9092),并订阅了指定的主题。消费者将从主题的开头开始消费消息,并在控制台中显示它们。要停止消费者,请按Ctrl + C

0