小小君

0 声望

这家伙太懒,什么都没留下

个人动态
  • 半兽人 回复 小小君kafka中文教程 中 :

    https://www.orchome.com/5#item-7
    这个会给你答案。

    3年前
  • 小小君 回复 半兽人kafka中文教程 中 :

    换个消费者组名是可以,但是我不知道是什么导致在使用相同的消费者组监听相同的topic而且远程服务没有宕机的情况下本地消费者抢到数据进行消费的(手动捂脸),虽然这种情况理论上不应该存在

    3年前
  • 小小君 回复 半兽人kafka中文教程 中 :

    还有个问题就是我批量消费kafka数据的时候,是设置的业务处理完之后再手动提交的。如果业务操作处理失败了,而我不想让它影响其他数据的消费,所以这把数据的offset记录到mysql,然后提交offset,定时任务去mysql获取失败的offset重新消费。请问我可以设置失败的时候不提交(也就是不持久化),然后跳过这条提交下一条数据,后续再重新消费这条,可以这样操作么

    3年前
  • 半兽人 回复 小小君kafka中文教程 中 :

    本地服务换个消费者组名。变成订阅模式。(注意:生产上根据你的业务做选择)

    3年前
  • 小小君 回复 半兽人kafka中文教程 中 :

    我试了下,远程服务用的storm整合的kafka,我本地不启动服务的情况下是可以正常消费数据的,但是我本地启动服务的话在我本地的服务基本就全部消费了,远程服务就消费不到了,除非我本地服务停掉。我的疑问是我本地的服务怎么抢到消费的呢?

    3年前