消费者组
-
Golang中Kafka消费者组无法提交offset怎么办
解决golang中kafka消费者组无法提交offset的问题,需先确认自动提交已关闭,再手动提交offset。1. 关闭自动提交:将enableautocommit设为false;2. 手动调用提交api,在消息处理完成后提交offset;3. 采用批量或定时异步提交策略提升性能;4. 完善错误处…
*本站广告为第三方投放,如发生纠纷,请向本站索取第三方联系方式沟通
解决golang中kafka消费者组无法提交offset的问题,需先确认自动提交已关闭,再手动提交offset。1. 关闭自动提交:将enableautocommit设为false;2. 手动调用提交api,在消息处理完成后提交offset;3. 采用批量或定时异步提交策略提升性能;4. 完善错误处…