如只需保证单key有序,为每个key申请单独内存 queue,每个线程分别消费一个内存 queue 即可,这样就能保证单key(例如用户id、活动id)顺序性。
javaKafka面试题-如何保证顺序消费
来源:图灵教育
时间:2024-05-27 13:40:23
单 topic,单partition,单 consumer,单线程消费,吞吐量低,不推荐;
最新推荐