Невозможно десериализовать данные GenericData avro в облачных потоках Spring kstreams - PullRequest
0 голосов
/ 08 апреля 2019

Невозможно десериализовать 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

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...