через Function<>. Используется кастомный десериализатор, который должен использовать потребитель и указан в конфиге. При запуске вижу, что мой десериализатор инициализируется, но для байндинга my-stream-function-in-0 используется io.confluent.kafka.streams.serdes.avro.SpecificAvroSerde. Из-за этого возникают ошибки десериализации. Как переопределить десериализатор?
https://spring.io/blog/2019/12/04/stream-processing-with-spring-cloud-stream-and-apache-kafka-streams-part-3-data-deserialization-and-serialization
Спасибо, попробую
Помогло. То есть указал кастомный SerDe через java конфиг. Спасибо!
Обсуждают сегодня