标题中这个错误是在apache nifi中使用avro序列化后结果发送到kafka中,然后从kafka中反序列化数据时出现的异常错误。通过各种调试,发现是由于Avro序列化后把schema信息也包含在datafile中,因此需要在发送数据之前将schema去掉,在Nifi中可以利用SplitAvro Processor将with schema选项置为false后去掉sheama。具体使用avro编程中,目前还未发现这个问题。

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

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

    • 2018年7月12日 at 下午10:14
      Permalink

      不是大神,小小程序猿一枚……

      Reply

鸟叔进行回复 取消回复

您的电子邮箱地址不会被公开。 必填项已用*标注

此站点使用Akismet来减少垃圾评论。了解我们如何处理您的评论数据