当Kafka主题中只有一个分区并且有多个使用者时,会发生什么?

har*_*der 2 apache-kafka

我有一个只有一个分区的Kafka主题,但在以下情况下我不会得到什么?消息将如何传递给消费者?

  1. 如果所有消费者都在同一组中
  2. 如果所有消费者都在不同的组中

在此处输入图片说明 我不确定消费者会收到唯一消息还是重复消息。

Nis*_*yal 5

每个使用者都订阅一个主题中的一个/多个分区。每个消费者都属于一个消费者组。以下是两种情况:

  1. 当所有使用者都属于同一组时:每个使用者将尝试订阅不同的分区。如果只有一个分区,则只有一个使用者获得消息,而其他使用者将处于空闲状态。

  2. 当所有使用者都属于不同的使用者组时:每个使用者将从所有分区中获取消息。分区订阅基于使用者组。

这取决于消费群体。提交读取偏移量后,同一使用者组中的使用者不会再从相同分区中读取数据。