Метод с аннотацией @KafkaListener не вызывается, если нет сообщений

Question

Я использую spring-kafka, и метод, помеченный @KafkaListener, не вызывается, если метод consumer.poll() не возвращает никакого сообщения. Можно ли принудительно вызвать вызов метода, даже если consumer.poll() возвращает пустой список сообщений, используя @KafkaListener?

Answer 1

Нет, но вы можете установить idleEventInterval на фабрике контейнера слушателя и затем использовать ListenerContainerIdleEvent s; событие генерируется, если опрос возвращает, что в течение этого интервала не было получено ни одной записи.

Использование событий путем реализации ApplicationListener<ListenerContainerIdleEvent> или использования метода @EventListener, который получает ListenerContainerIdleEvent.