如果为了消息的不重复消费,陪护老人13825404095而把生产端的重试机制关闭,消费端的手动提交改为自动提交,这样反而会出现消息丢失。那么可以直接在防止消息丢失的手段上加上消费消息时的幂等性特保证,便能解决重复消费的问题。消息积压会导致很多问题,比如:磁盘被打满、生产端发消息导致kafka性能过慢,就容易出现服务雪崩,就需要相应的处理手段。消费者订阅相应的topic,消费时轮询消费整个topic中的消息。消息发送者发送消息到相应的topic,并带上消息的发送时间。创建多个topic,每个topic表示延时的间隔。