我的Kafka分区有20个偏移量。我有一个消费群体的5个消费者订阅。我的问题是,是否有可能确保消费程序1读取前5个偏移量,成功读取后,消费程序2读取下5个偏移量,依此类推。。?如果不可能,那么是否有任何开源工具/技术可以这样做?
eoigrqb61#
属于同一消费者组的两个消费者不能从同一分区读取数据。如果只有一个分区,则一个使用者将使用所有20个偏移量,其余使用者将处于空闲状态,直到添加新分区。
1条答案
按热度按时间eoigrqb61#
属于同一消费者组的两个消费者不能从同一分区读取数据。如果只有一个分区,则一个使用者将使用所有20个偏移量,其余使用者将处于空闲状态,直到添加新分区。