【发布时间】:2019-05-01 10:27:33
【问题描述】:
我的 Kafka 分区有 20 个偏移量。我有一个由 5 个消费者订阅的消费者组。 我的问题是,是否有可能确保消费者 1 读取前 5 个偏移量,成功读取后,消费者 2 将读取接下来的 5 个偏移量,依此类推?如果不可能,那么是否有任何开源工具/技术可以这样做?
【问题讨论】:
-
我认为偏移量是指消息。您可以为主题设置多个分区,并且组中的每个使用者都从单独的分区中读取。您可以拥有自己的自定义逻辑来阻止其他消费者阅读,直到第一个消费者完成
标签: apache-kafka distributed-computing publish-subscribe distributed-transactions