kafka每消费一段时间 会出现部分分区不消费

yz、 发表于: 2021-03-12   最后更新时间: 2021-03-15 11:11:18   1,694 游览

问题描述

kafka 5个主题,每个主题5个分区。
一开始都是正常消费,但是消费一段时间后会出现部分分区不消费情况,需要重启后才能正常。

配置如下

screenshot
screenshot
screenshot

screenshot

代码

screenshot

发表于 2021-03-12
添加评论

ps:猜测,你没有提供相关的代码。
消息处理的地方捕获一下异常,如果消息处理异常,导致你该条处理异常往上抛错,可能会出现这种现象。

yz、 -> 半兽人 3年前

异常都捕获了,try catch并且finally 提交偏移量的。

半兽人 -> yz、 3年前

原因找到了吗?

yz、 -> 半兽人 3年前

没有找到原因呢。

半兽人 -> yz、 3年前

我也没看出来有其他的问题。
你的那些报错日志有打吗

你的答案

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