每次在python中运行consumer时,我都希望使用从开始到结束的所有消息,如果得到所需的记录,则停止并结束consumer,然后继续我的其余进程。
hivapdat1#
每次启动消费者时都可以使用seek(使用offset\u开头)。这会将分区的消耗位置设置为偏移。之后,继续像往常一样处理消息。当您遇到需要停止消费的记录时,请使用close
1条答案
按热度按时间hivapdat1#
每次启动消费者时都可以使用seek(使用offset\u开头)。这会将分区的消耗位置设置为偏移。之后,继续像往常一样处理消息。
当您遇到需要停止消费的记录时,请使用close