java - 消费者关闭后还能访问吗？

Question

每次运行后我都会关闭消费者，( consumer1.close() )希望避免不必要的运行，直到我希望消费者再次运行。当我调用它的运行函数时，我确实希望同一个消费者再次运行。但很明显，当我consumer1.poll()再次运行时，它说它已关闭。

有没有更好的方法来处理消费者只在需要时运行它？我也读过pause()和resume ()，它在节约资源方面的效果如何？

标签： javaapache-kafkakafka-consumer-api

Answer 1

每次启动消费者时，请确保使用相同的消费者组，以便您的消费者可以从消息被关闭之前的位置继续消费消息。

---

props.put("group.id", "my-consumer-group-id");
props.put("auto.offset.reset", "latest");