Как не найти больше сообщений в теме / разделе kafka и читать только после того, как завершена запись в topi c - PullRequest
0 голосов
/ 12 марта 2020

Я использую загрузочную версию Spring 1.5.4.RELEASE и Spring Kafka версии 1.3.8.RELEASE.

Некоторые общие вопросы c

  1. есть способ узнать больше нет сообщений в теме / разделе в потребителе
  2. как запустить потребителя, чтобы начать потреблять сообщения из топи c только после того, как запись от производителя завершена?

1 Ответ

1 голос
/ 12 марта 2020

Spring Boot 1.5 окончен и больше не поддерживается; текущая версия 2.2.5.

Последняя версия 1.3.x Spring для Apache Kafka - 1.3.10. Он будет поддерживаться только до конца этого года.

Вы должны планировать обновление.

Вы можете запускать и останавливать контейнеры с помощью компонента KafkaListenerEndpointRegistry; установите autoStartup на false на фабрике контейнеров.

См. Обнаружение неактивных и не отвечающих на запросы потребителей .

При эффективности одна проблема с асинхронным потребители обнаруживают, когда они бездействуют - пользователи могут захотеть предпринять какие-либо действия, если в течение некоторого периода времени не приходят сообщения.

Контейнер слушателя можно настроить для публикации sh a ListenerContainerIdleEvent, когда пройдет некоторое время без доставки сообщений. Во время простоя контейнера событие будет публиковаться каждые idleEventInterval миллисекунд.

...

...