消费者关闭后还能访问吗?

Can a consumer be accessed after it is closed?

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

是否有更好的方法来处理消费者 运行 仅在需要时才使用它?我还阅读了 pause()resume (),它在节约资源方面的效果如何?

每次启动消费者时,请确保使用相同的消费者组,以便您的消费者可以从关闭前留下的那一点继续消费消息。


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