Обработка сообщений Kafka Consumer - PullRequest
1 голос
/ 08 мая 2020

У меня три потребителя непрерывно опрашивают данные. Потребители потребляют данные, выполняют некоторую проверку и сохраняют смещение сообщения и некоторые детали сообщения в БД перед отправкой этого потребленного сообщения другому приложению. Как я могу обрабатывать свои сообщения, если моя БД не работает? каковы возможные решения для возобновления обработки сообщений без потери данных после того, как db будет запущен и работает?

...