Spark Streaming 2.0 读取Kafka 0.10 小例子

环境版本: Scala 2.11.8; Kafka 0.10.0.1; Spark 2.0.0java 如需Scala 2.10.5; Spark 1.6.0; Kafka 0.10.0.1版本请看这篇:Flume+Kakfa+Spark Streaming整合mysql import org.apache.kafka.common.serialization.StringDeserializer
相关文章
相关标签/搜索