【发布时间】: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