编程开发
未读
kafka消息堆积并不断重平衡导致重复消费
最近接手了一个积分服务，发现测试环境有一个提供给营销使用的topic，消费速度巨慢无比，5000条消费了半天，还有3000多条没有消费，并且kafka在不断重平衡。 查看代码，发现一个消息体中携带了50条数据，并且在一个for循环中一条一条处理。 消息体大概格式如下： {
"field1": 1
编程开发
未读
八股文系列——消息队列
消息队列有什么用？ 通常来说，消息队列有三个作用： 异步 削峰 解耦 除此之外，消息队列还有一个频繁使用的场景是延时队列。 异步 通过将次要操作异步处理，可以减少接口的响应时间，提高系统性能。 比如在购买火车票的场景中，用户在下订单时不需要立马发送短信通知，可以将发送短信通知放入消息队列中，由消费者