这家伙太懒,什么都没留下
兄弟,你解决了吗
目前分区是12个,6台机器
hatch.size=244260 linger.ms: 100 request.timeout.ms: 60000 max.request.size: 2097152
重试一次,还是会出现错误
1、可以考虑增加分区数来分摊压力2、batch.size 继续加大3、重试次数多加2次。
还是未有改善,目前来看,因为业务,kafka瞬间暴增60000条数据,才会导致这个错误
频率是否降低?