关于Kafka Cosumer异步commit offset的保序问题

Icarus 发表于: 2018-02-27   最后更新时间: 2018-02-27  
  •   27 订阅,507 游览

Kafka Consumer提供了异步api提交offset(即commitAsync()方法),

1 commitAsync(offset = 00001)
2 commitAsync(offset = 00002)
3 commitAsync(offset = 00003)

按照上面顺序执行,kafka broker能否保证最终存储的offset=00003?
如果请求3先到达broker,那么请求3提交的offset是否会被最终覆盖?或是不被覆盖,但请1、2被拒绝?







发表于: 3月前   最后更新时间: 3月前   游览量:507
上一条: kafka学了也有2个月了,但是一直不清楚SDK是怎么作为生产者来使用的,能否简单解释一下
下一条: 新kafka消费APi group delete 问题 谢谢!!!! ?????

评论…


  • 弄个一个AtomicLong atoOffset,用来存储已提交的offset,如果当前要提交的offset<atoOffset,则不提交
    弄个一个AtomicLong atoOffset,用来存储已提交的offset,如果当前要提交的offset<atoOffset,则不提交
    如果3先到,则3会被覆盖的。
  • 评论…
    • in this conversation
      提问