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

 kafka高級數據源拉取到spark，偏移量自我維護，藉助scalikejdbc寫入到mysql。java 須要導入mysql <dependency> <groupId>org.scalikejdbc</groupId> <artifactId>scalikejdbc_2.11</artifactId> <version>2.5.0</version> </dependency><!-- sc

>>阅读原文<<