Невозможно десериализовать avro GenericData в облачных потоках Spring KStreams.
В моем продюсере я сериализирую данные с использованием KafkaAvroSerializer class
и отправляю в kafka объект GenericData в формате avro. Но при десериализации даны следующие потребительские свойства.
key.deserializer: org.apache.kafka.common.serialization.StringDeserializer, value.deserializer:
io.confluent.kafka.serializers.KafkaAvroDeserializer
input.map(new KeyValueMapper<byte[], GenericData, KeyValue<String, String>>() {
@Override
public KeyValue<String, String> apply(byte[] s, GenericData genericRecord) {
// genericRecord
return new KeyValue<String, String>(s, genericRecord.toString());
}
});
Я хотел бы получить объект GenericData непосредственно в методе карты с десериализацией. но получаю ошибку.
java.lang.ClassCastException: [B не может быть приведен к org.apache.avro.generic.GenericData