знать что наше сообщение долетело или не долетело до kafka, нужно настраивать параметр acks и ловить колбэк при отправке?
Или как-то и без колбэка можно обработать Exception, если, например, kafka лежит а мы пытаемся в неё писать (Timeout Exception)?
Если брокера все лежат, то ты получишь Brokers may not be availability или подобное А Acks-ами это гарантии того 1) что сообщение вообще дошло до кафки 2) что оно записалось лидером 3) что и партиции тоже подсосали сообщение
Спасибо! И тогда дополнительный вопрос: А как обеспечиваются гарантии? Я на уровне логики получу какой-то Exception, если вдруг армагедон наступит? Нужно будет что-то обрабатывать?
Зависит от выбора acks
Обсуждают сегодня