如何在 Kafka 中添加消费组

要添加 Kafka 消费组,请执行以下步骤:

  1. 安装并启动 Kafka 服务。

  2. 创建一个新的消费组。

    使用以下命令:

    bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --create --group 'my-group'
    

    其中,'my-group' 是新消费组的名称。

  3. 将消费者加入消费组。

    您可以使用以下命令:

    bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic 'my-topic' --group 'my-group'
    

    其中 'my-topic' 是要消费的主题名称。

  4. 启动消费者并开始消费消息。

  5. 查看消费组状态 (可选)。

    您可以列出所有消费组并查看它们的状态:

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

    这将列出所有消费组的名称。

    要查看特定消费组的状态,请使用以下命令:

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

    其中 'my-group' 是要查看其状态的消费组的名称。

这些步骤将帮助您添加 Kafka 消费组并开始消费消息。

Kafka 添加消费组 - 详细步骤指南

原文地址: https://www.cveoy.top/t/topic/lyw4 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录