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