-1

每次我在 python 中运行消费者时，我想从头开始消费所有消息，如果我得到所需的记录并结束消费者，然后继续我的其余流程，则停止。

4

1 回答 1

1

每次启动消费者时都可以使用seek （使用 OFFSET_BEGINNING）。这会将分区的消耗位置设置为偏移。在此之后，继续照常处理消息。

当遇到需要停止Consumer的记录时，使用close

于 2019-02-21T05:43:36.787 回答