@StreamListener 在 ApplicationRunner 运行 执行之前开始消费
@StreamListener start to consume before ApplicationRunner run execute
我们正在使用 spring 云来使用来自 Kafka 的消息。
在@StreamListener 开始读取消息之前，我们需要在 class 实现 ApplicationRunner 中发出 HTTP 请求。在这个class中，我们停止与BindingsEndpoint.changeState的绑定，发送请求然后启用绑定。
但是，消息甚至在应用程序启动之前就被消耗了。
如何让@StreamListener 在 ApplicationRunner 之后工作？
或者在@StreamListener 之前有其他方法可以发出 http 请求？
将消费者 autoStartup 绑定 属性 设置为 false 以防止它在跑步者之前启动。
我们正在使用 spring 云来使用来自 Kafka 的消息。 在@StreamListener 开始读取消息之前，我们需要在 class 实现 ApplicationRunner 中发出 HTTP 请求。在这个class中，我们停止与BindingsEndpoint.changeState的绑定，发送请求然后启用绑定。
但是，消息甚至在应用程序启动之前就被消耗了。
如何让@StreamListener 在 ApplicationRunner 之后工作？
或者在@StreamListener 之前有其他方法可以发出 http 请求？
将消费者 autoStartup 绑定 属性 设置为 false 以防止它在跑步者之前启动。