【发布时间】:2019-03-26 19:59:43
【问题描述】:
我有一个只有一个分区的 Kafka 主题,但我不知道在以下情况下会发生什么?消息将如何传递给消费者?
- 如果所有消费者都在同一个组中
- 如果所有消费者都在不同的组中
【问题讨论】:
标签: apache-kafka
我有一个只有一个分区的 Kafka 主题,但我不知道在以下情况下会发生什么?消息将如何传递给消费者?
- 如果所有消费者都在同一个组中
- 如果所有消费者都在不同的组中
【问题讨论】:
标签: apache-kafka
每个消费者订阅一个主题中的一个/更多分区。每个消费者都属于一个消费者组。以下是两种情况:
当所有消费者属于同一个组时:每个消费者会尝试订阅不同的分区。如果只有一个分区,那么只有一个消费者会收到消息,而其他消费者将处于空闲状态。
当所有消费者属于不同的消费者组时:每个消费者都会从所有分区中获取消息。分区订阅基于消费者组。
这取决于消费者群体。提交读取偏移量后,同一消费者组中的消费者不会再次从同一分区读取数据。
【讨论】: