ли так сделать, чтобы он падал если broker не работает, а то он начинает спамить и никаких тебе exit 1?
А не поделитесь Вашей ситуацией - что послужило аргументом в пользу того, чтобы делать это на баше и этих утилитах?
Честно говоря не знаю, но может попробовать отрегулировать количество ретраев и политику ack в isr?
Грубо говоря нужно быстро реализовать healthcheck для kafka на виртуалках, который будет дергаться и если все плохо то будет запускаться recovery скрипт.
ок, понял, спасибо если интересно мое мнение, то я бы это сделал через jmx-метрики, конечно
Обсуждают сегодня