kafka 5个主题,每个主题5个分区。一开始都是正常消费,但是消费一段时间后会出现部分分区不消费情况,需要重启后才能正常。
ps:猜测,你没有提供相关的代码。消息处理的地方捕获一下异常,如果消息处理异常,导致你该条处理异常往上抛错,可能会出现这种现象。
异常都捕获了,try catch并且finally 提交偏移量的。
原因找到了吗?
没有找到原因呢。
我也没看出来有其他的问题。你的那些报错日志有打吗
找不到想要的答案?提一个您自己的问题。
0 声望
这家伙太懒,什么都没留下
ps:猜测,你没有提供相关的代码。
消息处理的地方捕获一下异常,如果消息处理异常,导致你该条处理异常往上抛错,可能会出现这种现象。
异常都捕获了,try catch并且finally 提交偏移量的。
原因找到了吗?
没有找到原因呢。
我也没看出来有其他的问题。
你的那些报错日志有打吗
你的答案