编程开发
未读
kafka消息堆积并不断重平衡导致重复消费
最近接手了一个积分服务，发现测试环境有一个提供给营销使用的topic，消费速度巨慢无比，5000条消费了半天，还有3000多条没有消费，并且kafka在不断重平衡。 查看代码，发现一个消息体中携带了50条数据，并且在一个for循环中一条一条处理。 消息体大概格式如下： {
"field1": 1