安东尼的不二情

0 声望

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

个人动态

半兽人 回复 安东尼的不二情 kafka 没有提交偏移量为什么还消费不到消息 中 :
kafka客户端负责把消息丢给你的业务层,这个时候,该消息必须被提交,无论你业务层是否成功,而且kafka是基于offset下标的,如果后面的提交也会跳过之前的消息。另外设计第一原则是不要侵入到业务层。 如果业务处理这条消息失败,重新丢会队列或者其他的处理就可以了,简单不复杂。
7月前
安东尼的不二情 回复 半兽人 kafka 没有提交偏移量为什么还消费不到消息 中 :
哪有什么好点的重试策略吗
7月前
半兽人 kafka 没有提交偏移量为什么还消费不到消息 发表评论:
是呀,kafka客户端已经将消息拉下来了,也丢给你了,你不提交offset,那客户端也不会重新去拉取了,它认为你在处理中。
7月前
咖啡店的卡尔萨斯 回复 安东尼的不二情 kafka在正在运行的集群中整合安全功能 中 :
这个是升级过程中集群中的broker listen name没有对齐的原因,都升级了就好了
9月前

(゚∀゚ )
暂时没有任何数据