这家伙太懒,什么都没留下
感谢大佬抽空解答,原因找到了,是因为测试账号限流了。
代码封装的太多了,我看不出来里面的逻辑,有2种可能。1、当消息接收后,任何异常自己消化,不要往上抛。2、进程结束,需要休眠或者优雅停机,否则有可能造成你还没提交offset成功,进程已经结束了。
不会,参考消费者组的作用:https://www.orchome.com/5#item-7
topic和groupid一样开5个java进程,会不会重复消费?