异常解决:org.apache.avro.AvroRuntimeException: Malformed data. Length is negative: -40

标题中这个错误是在apache nifi中使用avro序列化后结果发送到kafka中,然后从kafka中反序列化数据时出现的异常错误。通过各种调试,发现是由于Avro序列化后把schema信息也包含在datafile中,

pt async src="//pagead2.googlesyndication.com/pagead/js/adsbygoogle.js">