Cuando intenté correrKafka Consumer con Avro sobre los datos con mi esquema respectivo, devuelve un error de "AvroRuntimeException: datos con formato incorrecto. La longitud es negativa: -40". Veo que otros han tenido problemas similaresconvertir la matriz de bytes a json, Avro escribe y leeyCodificador binario * Kafka Avro. También he hecho referencia a estoEjemplo de grupo de consumidores, que han sido útiles, sin embargo, hasta ahora no han ayudado con este error. Funciona hasta esta parte del código (línea 73)

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

Probé otros decodificadores e imprimí el contenido de la variable byteArrayInputStream, que se ve como creo que esperarías que se vean los datos serializados de avro (en el mensaje puedo ver el esquema y algunos datos y algunos datos con formato incorrecto). Bytes disponibles con el método .available (), que devuelve 594. Tengo problemas para comprender por qué ocurre este error. Apache Nifi se utiliza para producir la secuencia de Kafka con el mismo esquema de hdfs. Apreciaría cualquier ayuda.