Sat*_*Sat 17 apache-kafka kafka-consumer-api
producer 发送消息1,2,3,4
consumer 接收消息1,2,3,4
consumer 崩溃/断开
producer 发送消息5,6,7
consumer 恢复,应该从5而不是7开始收到消息
对于这种结果,offset我必须使用哪个值以及需要做哪些其他更改/配置
ppa*_*rno 22
当一个使用者加入一个使用者组时,它将获取最后一个提交的偏移量,因此如果在崩溃之前它将重新启动以从5,6,7读取它提交了最新的偏移量(所以4).当使用者启动时,将使用属性的earliest和latest值,auto.offset.reset但是已分配的分区没有已提交的偏移量.在这种情况下,您可以选择是否要从头(最早)或最后一个(最晚)之后重新读取所有消息.
| 归档时间： |
|
| 查看次数： |
18035 次 |
| 最近记录： |