Spring Boot 1.5 окончен и больше не поддерживается; текущая версия 2.2.5.
Последняя версия 1.3.x Spring для Apache Kafka - 1.3.10. Он будет поддерживаться только до конца этого года.
Вы должны планировать обновление.
Вы можете запускать и останавливать контейнеры с помощью компонента KafkaListenerEndpointRegistry
; установите autoStartup
на false
на фабрике контейнеров.
См. Обнаружение неактивных и не отвечающих на запросы потребителей .
При эффективности одна проблема с асинхронным потребители обнаруживают, когда они бездействуют - пользователи могут захотеть предпринять какие-либо действия, если в течение некоторого периода времени не приходят сообщения.
Контейнер слушателя можно настроить для публикации sh a ListenerContainerIdleEvent
, когда пройдет некоторое время без доставки сообщений. Во время простоя контейнера событие будет публиковаться каждые idleEventInterval
миллисекунд.
...