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

時間 2020-08-26

標籤 sparkstreaming 整合 kafka 參數設置 message 偏移量寫入 redis 欄目 Kafka 简体版

原文原文鏈接

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>

>>阅读原文<<