Я публикую сообщения для внешней команды, которая получает сообщения для Kafka и возвращает нам ответ. Всякий раз, когда наше приложение работает и пытается отправить сообщение о публикации в Kafka, и если соединение с Kafka потеряно или отключено, наше приложение выдает исключение. Я хочу, чтобы мое приложение не ломалось, даже если соединение с Kafka разорвано. Темы Kafka обрабатываются другой командой, и я не могу изменить их код. Есть ли способ, которым я могу сохранить свое приложение, минуя шаг Kafka, и продолжить другую обработку без каких-либо последствий?
Приложение должно продолжать работать даже после разрыва соединения с Kafka.
Ответы (1)
Вы можете увеличить конфигурацию производителя retries и установить большое число, например, Integer.MAX_VALUE.
person
Matthias J. Sax
schedule
16.06.2019
Я увеличил количество попыток. Тем не менее, это не работает
- person Shwetali Khandelwal; 22.06.2019
Что значит не работает конкретно? Какую ошибку/исключение вы получаете?
- person Matthias J. Sax; 22.06.2019
Kafka подключается, а затем отображается регистратор - жесткое отключение. Также не удается выполнить проверку работоспособности API.
- person Shwetali Khandelwal; 22.06.2019
Можете поделиться сообщением об ошибке? Просто обновите свой вопрос.
- person Matthias J. Sax; 22.06.2019
