【问题标题】:How to create Kafka consumer group using command line?如何使用命令行创建 Kafka 消费者组?
【发布时间】:2020-08-17 16:54:02
【问题描述】:

我正在使用 Confluent 5.2 的社区版本。我创建了一个名为 employee-info 的新主题。

我使用 flink 作为上述主题的消费者。在 flink 中,要添加 kafka 源,我们需要传入group.id(消费者组)作为参数。如何为我的主题创建新的消费者组?我几乎没有提到使用kafka-consumer-group--consumer-property group.id=group_name。但是,当我运行 kafka-consumer-group --help

时,我看不到该选项

【问题讨论】:

    标签: apache-kafka


    【解决方案1】:

    您无需显式“准备”Kafka 代理即可添加新的消费者组。

    只需在您的 Flink 消费者中添加 group.id,代理将自动检测此 group.id 是新的还是已经存在。

    kafka-consumer-group.sh命令行主要用于管理现有组,以获取当前的偏移量,或者重置它们,查看不同的成员,...

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多