非常棒的实战记录!!
有个地方没看懂,想请教一下,最后的修改方案中“3.poll到的消息,处理完一条就提交一条”,
假设poll之前的offset是100,这次循环中poll到了50条记录,
期待的动作是循环处理这50条记录,每处理完一条调用commit,把offset加1,50条循环完后offset被逐次更新到150.
但是没看明白的地方是,每次for循环处理完其中第一条后调用consumer.commitSync();
这样会不会在处理完第一条后就把offset更新到了150呀?是怎么控制的每个循环让offset加1的呢?
记一次线上kafka一直rebalance故障今天我司线上kafka消息代理出现错误日志,异常rebalance,而且平均间隔2到3分钟就会rebalance一次,分析日志发现比较严重。错误日志如下 这个错误的意思是,消...