我有一个只有一个分区的Kafka主题,但在以下情况下我不会得到什么?消息将如何传递给消费者?
如果所有消费者都在同一组中
如果所有消费者都在不同的组中
每个使用者都订阅一个主题中的一个/多个分区。每个消费者都属于一个消费者组。以下是两种情况:
当所有使用者都属于同一组时:每个使用者将尝试订阅不同的分区。如果只有一个分区,则只有一个使用者获得消息,而其他使用者将处于空闲状态。
当所有使用者都属于不同的使用者组时:每个使用者将从所有分区中获取消息。分区订阅基于使用者组。
这取决于消费群体。提交读取偏移量后,同一使用者组中的使用者不会再从相同分区中读取数据。