Kafka 的工作方式与 SQS 略有不同。
每条消息都驻留在一个主题分区上。Kafka 消费者被组织成消费者组。单个分区只能分配给组中的单个消费者。这意味着来自同一 CG 的其他消费者不会收到相同的消息,并且只有当同一消费者从代理提取消息并且尚未提交偏移量时才会重新发送相同的消息。
如果指定为组协调器的 Kafka 代理检测到消费者死亡,则会发生重新平衡,并且该分区可以分配给另一个消费者。但这将是唯一从该分区获取消息的消费者。
正如您所看到的,由于 Kafka 没有使用竞争的消费者模式,因此不存在 的概念visibility timeout。
| 归档时间: |
|
| 查看次数: |
916 次 |
| 最近记录: |