【发布时间】:2021-03-21 15:05:21
【问题描述】:
- 生产者依次发送1、2、3、4条消息,1、2、3未确认。
- 消费者重启后,会重复消费1、2、3,消费者发送消息4,消费者确认
- 重启后消费者不会再收到1、2、3
卡夫卡有没有机制可以保留未识别的1、2、3?
或者你必须自己处理消息
【问题讨论】:
标签: apache-kafka apache-kafka-streams spring-kafka
卡夫卡有没有机制可以保留未识别的1、2、3?
或者你必须自己处理消息
【问题讨论】:
标签: apache-kafka apache-kafka-streams spring-kafka
这就是卡夫卡的工作方式;个人记录未得到确认;每个消费者的每个分区内只有一个提交的偏移量。
您可以查找分区的开头,但您也会得到 1、2、3 和 4。
【讨论】: