中通消息平台 Kafka 顺序消费线程模型的实践与优化

各种消息中间件对顺序消息实现的作法是将具备顺序性的一类消息发往相同的主题分区中,只须要将这类消息设置相同的 Key 便可,而 Kafka 会在任意时刻保证一个消费组同时只能有一个消费者监听消费,所以可在消费时按分区进行顺序消费,保证每一个分区的消息具有局部顺序性。因为须要确保分区消息的顺序性,并不能并发地消费消费,对消费的吞吐量会形成必定的影响。那么,如何在保证消息顺序性的前提下,最大限度的提升消
相关文章
相关标签/搜索