sparkstreaming对接kafka将数据批量插入数据库(java版本)
话不多说先上代码import DBUtils.Databases;import org.apache.kafka.clients.consumer.ConsumerRecord;import org.apache.kafka.common.TopicPartition;import org.apache.kafka.common.serialization.StringDeserializ...