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