解决sparkstreaming读取kafka中的json数据,消费后保存到MySQL中,报_corrupt_record和name错误的!!
所用软件版本: spark2.3.0 IDEA2019.1 kafka_2.11-01.0.2.2 spark-streaming-kafka-0-10_2.11-2.3.0 先贴出代码: package com.bd.spar
2024-10-17880
所用软件版本: spark2.3.0 IDEA2019.1 kafka_2.11-01.0.2.2 spark-streaming-kafka-0-10_2.11-2.3.0 先贴出代码: package com.bd.spar
