Метод с аннотацией @KafkaListener не вызывается, если нет сообщений
Вы не должны ссылаться на свой класс по пути к каталогу, а по пути его пакета. Пример:
/Users/_name_here/dev/spark/bin/spark-submit
--master local[4]
--class com.example.MySimpleApp /Users/_name_here/dev/sp/target/scala-2.10/sp_2.10-0.1-SNAPSHOT.jar
Из того, что я вижу, у вас нет MySimpleApp в любом пакете, так что просто «--class MySimpleApp» должен работать.
1
задан cegas 28 March 2019 в 12:34
поделиться
1 ответ
Нет, но вы можете установить idleEventInterval на фабрике контейнера слушателя и затем использовать ListenerContainerIdleEvent с; событие генерируется, если опрос возвращает, что в течение этого интервала не было получено ни одной записи.
Поглотить события, реализовав ApplicationListener<ListenerContainerIdleEvent> или используя метод @EventListener, который получает ListenerContainerIdleEvent.
0
ответ дан Gary Russell 28 March 2019 в 12:34
поделиться
Другие вопросы по тегам: