sparkStreaming的offset保存在redis中

實現功能:javascript 從kafka讀取某一主題,消費者組的偏移量html 基於讀出的offset,建立kafka讀取流程java 把各個分區的偏移量 保存到redis。web import Kafka010.Utils.{MyKafkaUtils, RedisUtilsDemo} import org
相關文章
相關標籤/搜索