только после того как дерну продюсер.
он вроде сам стартует когда сообщения попадают в топик
Что-то вот не стартует. Kafkalytic`ом закидываю сообщение. Не видит. И в инфошках не отображается конфиг консьюмера и его подписки на топики
а что в опции стоит за значение auto.offset.reset
Не выставлено
Поставьте earliest
Это несколько про другое. Сам консьюмер норм читает. Просто не инициализируется после старта приложения. В класс, который содержит метод @KafkaListener добавил пока костыль в виде метода с аннотацией @EventListener(ApplicationReadyEvent.class).
Обсуждают сегодня