117笔记问答Kafka 消费者命令用于从 Kafka 集群中消费消息
-
首先，确保你已经安装了 Kafka 和相关的客户端工具。如果没有，请参考 Apache Kafka 官方文档 进行安装。
-
创建一个消费者组。消费者组是一组共享同一个组ID的消费者实例。在同一组内的消费者可以分配不同的分区来消费消息。要创建一个消费者组，你可以使用以下命令：
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --create --group my-consumer-group
- 使用
kafka-console-consumer.sh脚本消费消息。这个脚本允许你从一个或多个主题中消费消息。要使用此脚本，请运行以下命令：
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-topic --from-beginning --group my-consumer-group
这里，--bootstrap-server 参数指定了 Kafka 集群的地址，--topic 参数指定了要消费的主题，--from-beginning 参数表示从消息的开始位置消费，--group 参数指定了消费者组ID。
- 若要停止消费者，可以按
Ctrl + C。
注意：在实际应用中，你可能需要使用编程语言（如 Java、Python、Go 等）编写消费者程序来消费消息。在这种情况下，你需要使用 Kafka 客户端库（如 confluent-kafka-python）来编写消费者代码。