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
相关文章
相关标签/搜索