Я пытаюсь выяснить, как обработать исключение с ошибочным сообщением Avro.В настоящее время я получаю
{"@timestamp":"2019-06-13T20:20:38.636+00:00","@version":1,"message":"[Incoming aggregation] Upstream failed.","logger_name":"akka.stream.Materializer","thread_name":"system-akka.actor.default-dispatcher-5","level":"ERROR","level_value":40000,"stack_trace":"org.apache.kafka.common.errors.SerializationException: Error deserializing key/value for partition conversation-7 at offset 1737997. If needed, please seek past the record to continue consumption.\nCaused by: org.apache.kafka.common.errors.SerializationException: Error deserializing Avro message for id 42\nCaused by: java.lang.ArrayIndexOutOfBoundsException: 51
Как видно, это прерывает поток.Я не могу справиться с этим в решающем вопросе, так как он является частью Источника Потребителя.В документах говорится, что я должен прочитать поток как необработанные байты и выполнить синтаксический анализ вручную на этапе потока далее в цепочке обработки.Однако я не думаю, что это возможно, если я использую реестр Schema.
Может кто-нибудь дать мне подсказку о том, как правильно это обрабатывать?
Спасибо