Получение ошибок при десериализации сообщения от Кафки с использованием схемы AVRO ⇐ Apache

[Anonymous]

Я пытаюсь десериализировать запись кафки, потребляемую из темы Кафки, используя приведенный ниже код, даже если схема верна, мы сталкиваемся с ошибкой. Можете ли вы предложить, что еще может быть неверным. < /p>
code < /p>
import org.apache.avro.Schema;
import org.apache.avro.generic.GenericRecord;
import org.apache.avro.specific.SpecificDatumReader;

public class AvroUtility {

private static final org.slf4j.Logger log = org.slf4j.LoggerFactory.getLogger(Replicator.class);

public SpecificDatumReader datumReader() {
String valueSchemaString = null;
valueSchemaString = "my schema in form of json string"
Schema avroValueSchema = new Schema.Parser().parse(valueSchemaString);
SpecificDatumReader datumReader = new SpecificDatumReader(avroValueSchema);
return datumReader;
}
}
< /code>
Мы использовали приведенный выше класс Avroutility в ниже кода < /p>
ConsumerRecord record

BinaryDecoder binaryDecoder = DecoderFactory.get().binaryDecoder(record.value(), null);
GenericRecord deserializedValue = datumReader.read(null, binaryDecoder);
< /code>
Мы получаем ниже ошибку < /p>
org.apache.avro.AvroRuntimeException: Malformed data. Length is negative: -1
at org.apache.avro.io.BinaryDecoder.readString(BinaryDecoder.java:308)
at org.apache.avro.io.ResolvingDecoder.readString(ResolvingDecoder.java:208)
at org.apache.avro.generic.GenericDatumReader.readString(GenericDatumReader.java:469)
at org.apache.avro.generic.GenericDatumReader.readString(GenericDatumReader.java:459)
at org.apache.avro.generic.GenericDatumReader.readWithoutConversion(GenericDatumReader.java:191)
at org.apache.avro.specific.SpecificDatumReader.readField(SpecificDatumReader.java:136)
at org.apache.avro.generic.GenericDatumReader.readRecord(GenericDatumReader.java:247)
at org.apache.avro.specific.SpecificDatumReader.readRecord(SpecificDatumReader.java:123)
at org.apache.avro.generic.GenericDatumReader.readWithoutConversion(GenericDatumReader.java:179)
at org.apache.avro.specific.SpecificDatumReader.readField(SpecificDatumReader.java:136)
at org.apache.avro.generic.GenericDatumReader.readRecord(GenericDatumReader.java:247)
at org.apache.avro.specific.SpecificDatumReader.readRecord(SpecificDatumReader.java:123)
at org.apache.avro.generic.GenericDatumReader.readWithoutConversion(GenericDatumReader.java:179)
at org.apache.avro.specific.SpecificDatumReader.readField(SpecificDatumReader.java:136)
at org.apache.avro.generic.GenericDatumReader.readRecord(GenericDatumReader.java:247)
at org.apache.avro.specific.SpecificDatumReader.readRecord(SpecificDatumReader.java:123)
at org.apache.avro.generic.GenericDatumReader.readWithoutConversion(GenericDatumReader.java:179)
at org.apache.avro.generic.GenericDatumReader.read(GenericDatumReader.java:160)
at org.apache.avro.generic.GenericDatumReader.read(GenericDatumReader.java:153)
at com.myapp.nac.controller.Replicator.lambda$replicator$0(Replicator.java:116)
at java.lang.Iterable.forEach(Iterable.java:75)
at com.myapp.controller.Replicator.replicator(Replicator.java:104)
at com.myapp.nac.SpringBootWithKafkaApplication.main(SpringBootWithKafkaApplication.java:21)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.springframework.boot.loader.MainMethodRunner.run(MainMethodRunner.java:48)
at org.springframework.boot.loader.Launcher.launch(Launcher.java:87)
at org.springframework.boot.loader.Launcher.launch(Launcher.java:51)
at org.springframework.boot.loader.PropertiesLauncher.main(PropertiesLauncher.java:597)


Подробнее здесь: https://stackoverflow.com/questions/795 ... vro-schema