kafka消费topic过程中出现的个别bug情况如何处理？

Tobey 发表于: 2019-06-21   最后更新时间: 2019-06-29 15:56:05   2,144 游览

提问说明

前提：我要消费topic执行Java逻辑，逻辑完成后手动提交offset。 问题：如果我因为有bug所有的消费都抛异常没有提交offset,这样重启消费端即可。但是如果我只是个别的发生了错误后面的正常offset就会被提交覆盖。那出现异常的个别topic应该如何处理。

kafka
发表于 2019-06-21
Tobey

业务逻辑不要影响kafka的消费逻辑，kafka属于公共逻辑，把消息丢给业务层，业务自己处理报错就自己消化。

回复
回答于 4年前
半兽人
半兽人 -> 半兽人 4年前

另外，kafka消费的位置是offset控制的，所以后面提交offset会跳过前面的。kafka的特性

0 0 回复
Tobey -> 半兽人 4年前

有道理，但是我把错误记入日志后bug也修改了想要再消费一次这个消息怎么办。

0 0 回复
半兽人 -> Tobey 4年前

重新丢回topic里。或者丢到异常topic里。

0 0 回复
Tobey -> 半兽人 4年前

这个topic是新增组成员时发出的，无法再次操作新增组成员了啊。难道我再单独写个接口专门手动请求处理这种有bug的消息。

0 0 回复
半兽人 -> Tobey 4年前

没懂…

0 0 回复
Tobey -> 半兽人 4年前

我的意思是一般处理这种个别bug的消息是怎么丢回topic的，是写一个专门的接口手动请求添加进去还是有其它好方法。

0 0 回复
半兽人 -> Tobey 4年前

业务调生产者丢回去

0 0 回复
Tobey -> 半兽人 4年前

好吧 就这样。

0 0 回复
你的答案

查看kafka相关的其他问题或提一个您自己的问题。
提问

找不到想要的答案？提一个您自己的问题。