apache-kafka - Kafka 消费者默认组 ID

Question

我正在使用 Apache Kafka 及其 Java 客户端，我看到消息在属于同一组的不同 Kafka 消费者之间进行负载平衡(即共享相同的组 ID)。

在我的应用程序中，我需要所有消费者阅读所有消息。

所以我有几个问题:

如果我没有在 Consumer Properties 中设置任何组 id，那么 Kafka 消费者将被赋予什么组 id？

有单一的默认值吗？

客户端是否每次都创建一个随机值？

我是否需要为每个消费者创建不同的 id 以确保每个消费者都收到所有消息？

编辑:
谢谢您的回答。

你是对的:如果没有设置消费者组 ID，卡夫卡应该提示。

但是，我发现如果 group id 为 null，Java 客户端将其设置为空字符串 ""以避免出现问题。
所以显然这是我正在寻找的默认值。

令我所有的消费者感到惊讶，即使我没有设置他们的 groupId(所以他们都使用 groupId == "")似乎收到了生产者写的所有消息。

我仍然无法解释这一点:有什么建议吗？

Answer 1

我有同样的问题。并花了一些时间研究这个问题。
项目spring-cloud-stream将检查您是否为消费者设置了组 ID。如果没有，spring-cloud-stream将创建一个随机值作为组 ID。
请引用方法createConsumerEndpoint在类里面KafkaMessageChannelBinder.