Spark:zookeeper或者Kafka记录偏移量
Spark:2.4 ,适用于Kafka:0.10.0及以上1. zookeeper记录偏移量object KafkaDirectWordCount_zookeeper { def main(args: Array[String]): Unit = { val group = "g001" val topic = "wordcount" val topics = A...