事件完成后启动kafka消费者

Question

我的Spring启动应用程序执行两项任务

1. 初始化缓存
2. 卡夫卡消费者

已经有一个用于缓存初始化的ApplicationEvent，我希望消费者在缓存初始化完成后开始侦听消息。

Answer 1

如果使用的是@KafkaListener，请给它一个id，并将autoStartup设置为false。

准备好后，使用KafkaListenerEndpointRegistrybean启动容器。

registry.getMessageListenerContainer("myId").start()。

如果您使用的是侦听器容器bean，请将其autoStartup设置为false，并在准备好时将其设置为start()。