Wenn ich versucht habe zu rennenKafka Consumer mit Avro Über den Daten mit meinem jeweiligen Schema wird der Fehler "AvroRuntimeException: Fehlerhafte Daten. Länge ist negativ: -40" zurückgegeben. Ich sehe, dass andere ähnliche Probleme hattencoverting byte array to json, Avro schreiben und lesen, undKafka Avro Binary * coder. Ich habe auch dieses @ verwiesConsumer Group Beispiel, die alle hilfreich waren, aber bisher keine Hilfe bei diesem Fehler. Es funktioniert bis zu diesem Teil des Codes (Zeile 73)

Decoder decoder = DecoderFactory.get (). BinaryDecoder (byteArrayInputStream, null);

Ich habe andere Decoder ausprobiert und den Inhalt der Variable byteArrayInputStream ausgedruckt. Ich glaube, dass die serialisierten AVRO-Daten so aussehen (in der Meldung, dass ich das Schema und einige Daten und einige fehlerhafte Daten sehen kann, habe ich den Ausdruck Die verfügbaren Bytes mit der .available () -Methode, die 594 zurückgibt. Ich habe Probleme zu verstehen, warum dieser Fehler auftritt. Apache Nifi wird verwendet, um den Kafka-Stream mit demselben Schema aus hdfs zu erzeugen. Ich würde mich über jede Hilfe freuen.