Потоки Kafka с определенным параметром: Как настроить обработчик исключений десериализации

#apache-kafka #apache-kafka-streams #confluent-platform Вопрос: Я хочу пропустить сообщения, которые не десериализуются. Можно ли настроить обработку исключений десериализации в Confluent SpecificAvroSerde ( io.confluent.kafka.streams.serdes.avro.SpecificAvroSerde ) и как? Кстати: default.deserialization.exception.handler опция, похоже, поддерживается…

Продолжить чтениеПотоки Kafka с определенным параметром: Как настроить обработчик исключений десериализации