azure - 了解 Azure EventHub 中的 ConsumerGroup 行为

Question

我正在编写一个发布/订阅实现，它使用 Azure EventHub 作为底层事件引入服务。在我的应用程序中，发布者将事件发布到特定的 EventHub 分区，订阅该特定分区的消费者将接收事件。通常，一个消费者会被分配到一个唯一的 EventHub ConsumerGroup，并且在某些情况下，可以有多个消费者分配给同一个 ConsumerGroup。

假设我在同一个 ConsumerGroup (consumer-group-1) 中有两个消费者 (consumer-1、consumer-2)，他们订阅了特定 EventHub 分区(event-hub-1 的分区“0”)的事件)。

当我们将事件发送到“event-hub-1”的分区“0”时，消息传递将如何发生？

• 两个消费者(consumer-1、consumer-2)会收到相同的消息吗？
• 或者 ConsumerGroup 是否会像传统 Kafka 一样在消费者之间对消息进行负载均衡，并且只有一个消费者收到消息？

示例代码:https://github.com/ballerina-platform/ballerina-standard-library/issues/3483#issuecomment-1272824977

注意:申请写在 ballerina language其内部使用 Kafka Java Client

Answer 1

顾名思义，消费者组是“消费者组”。每个消费者组都会获取该消息的副本，并且该消费者组中的一个消费者会收到该消息。因此，对于您的场景，consumer-1 或consumer-2 都会收到消息，因为它们位于同一个consumergroup 中。