spring-cloud-stream - Spring Cloud Stream中BindingServiceConfiguration.inputBindingLifecycle()方法有什么用？

Question

我想知道Spring Cloud Stream(for Kafka)中BindingServiceConfiguration.inputBindingLifecycle()方法的使用，以及该方法对可能的业务场景有帮助吗？

标签： spring-cloud-stream

Answer 1

start()当应用程序准备好启动和stop()关闭应用程序时，框架使用它来绑定。

它并不是真正打算让用户代码调用它，尤其是使用 Kafka，因为停止它会导致分区的重新平衡。

如果您想暂时停止接收消息（同时不允许将分区分配给另一个实例），最好使用执行器暂停/恢复。