天天看點

kafka SparkStreaming讀取資料筆記

取決于 enable.auto.commit”

enable.auto.commit” -> (true: java.lang.Boolean) 可以儲存offset,可以讀取錯過消息。(即使沒有checkpoint)

不開自動送出的話 offset取決于 auto.offset.reset”

0.9以後offset已經和zk沒關系