将KafKa的偏移量写入Mysql
package SparkStreamingKafKa.OffSetMysqlimport java.sql.{DriverManager, ResultSet}import com.typesafe.config.{Config, ConfigFactory}import org.apache.kafka.clients.consumer.ConsumerRecordimport o...
