阻止 kafka 消费者消费消息

Question

有什么方法可以阻止 kafka 消费者在一段时间内消费消息？ 我希望消费者停止一段时间，然后开始消费最后一条未消费消息中的消息。

Answer 1

大多数 Kafka 库在 Consumer 实现上都有 close 或 pause 方法。或者，您可以在消费期间抛出一些致命异常。

从消费者组的最后一个未提交的偏移量恢复是默认行为