sparkstreaming整合kafka參數設置，message偏移量寫入redis

 kafka高級數據源拉取到spark，偏移量自我維護寫入到redis,創建redis鏈接池。java 須要導入redis <groupId>org.apache.spark</groupId> apache <artifactId>spark-streaming-kafka-0-10_2.11</artifactId> <version>2.2.1</version> </dependency>

>>阅读原文<<