нужна помощь.Мне нужно подтверждение того, как KSQL обрабатывает следующую ошибку:
org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition.?
Поскольку у нас были реальные проблемы с этим, когда были представлены новые брокеры.Стримеры большого объема перешли в состояние ошибки и не смогли восстановиться, и их не убили.Это продолжалось почти несколько дней, пока некоторые клиенты не пожаловались, что не получают уведомления.Мы обработали этот сценарий, зарегистрировав глобальный обработчик исключений, который перезапускает потоки:
streams.setUncaughtExceptionHandler((Thread thread, Throwable throwable) -> {
// here you should examine the throwable/exception and perform an appropriate action!
});
Мы планируем адаптировать KSQL для некоторых случаев использования сейчас.Но основная проблема заключается в том, как справиться с этим сценарием в KSQL.Может кто-нибудь подсказать какое-нибудь мнение эксперта.
Этот вопрос очень сложно воспроизвести.Я попытался запустить несколько брокеров в моем регионе и убить лидера, но мой производитель потерпел неудачу, в то время как потребитель работал хорошо.Так что очень трудно повторить то же самое, поэтому спрашиваю мнение эксперта, который действительно сталкивался с подобной проблемой в KSQL.