запускать потребителя kafka после завершения события

Question

Мое загрузочное приложение Spring выполняет две задачи

1. Инициализирует кеш
2. kafka consumer

Уже есть ApplicationEvent для инициализации кеша, и я хочу, чтобы потребитель начать прослушивание сообщений после завершения инициализации кеша.

Answer 1

Если вы используете @KafkaListener, присвойте ему id и установите autoStartup на false.

Когда будете готовы, используйте bean-компонент KafkaListenerEndpointRegistry для запуска контейнера.

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

Если вы используете bean-компонент контейнера слушателя, установите для него autoStartup значение false и start(), когда оно будет готово.