Иногда я вижу ниже ошибку, которая потребляет весь журнал, и даже задание перезапускается.
Хотел узнать, как перехватить эти исключения в flink.
ERROR org. apache .kafka.clients.producer.internals.Sender - [Producer clientId = abcedef] Необработанная ошибка в потоке ввода-вывода производителя kafka: java .lang.IllegalStateException: Не найдена запись для соединения 2 в org. apache. kafka.clients.ClusterConnectionStates.nodeState (ClusterConnectionStates. java: 339) в org. apache .kafka.clients.ClusterConnectionStates.disconnected (ClusterConnectionStates. java: 143). org .kaf. org .ka. NetworkClient.initiateConnect (NetworkClient. java: 926) в орг. apache .kafka.clients.NetworkClient.access $ 700 (NetworkClient. java: 67) в орг. apache .kafka.clients.NetworkClient $ DefaultMetadataUp .maybeUpdate (NetworkClient. java: 1090) в орг. apache .kafka.clients.NetworkClient $ DefaultMetadataUpdater.maybeUpdate (NetworkClient. java: 976) в орг. apache .kafka.clients.Network. опрос (NetworkClient. java: 533) в орг. apache .kafka.clients.producer.internals.Sender.run (Отправитель. java: 311) в орг. apache .kafka.clients.producer. internals.Sender.run (Отправитель. java: 235) в java .lang.Thread.run (Тема. java: 748)