kafka生产者报错CORRUPT_MESSAGE

kafka生产者时不时报这个错

spark-streaming-kafka-0-10_2.11 用spark处理数据，对某些符合条件的数据发送到kafka

 producer.send(new ProducerRecord<String,Notify>(topic, data), (metaData, exception) -> {
    if (exception != null) {
       log.error(exception)
     }
 });

错误信息