Kafka stream con AVRO Serde personalizado (sin esquema)
Tengo una aplicación de procesamiento de flujo que utiliza el formato de mensaje AVRO. Para la serialización y deserialización (Serde) se utiliza io.confluent.kafka.streams.serdes.avro.GenericAvroSerde. Intenté crear un Serde AVRO personalizado como el siguiente: public class CustomAvroSerde implements Serde { Class<SpecificRecord> targetType; public CustomAvroSerde() { } public CustomAvroSerde(Class<SpecificRecord> targetType) { this.targetType = . . . Read more