取決于 enable.auto.commit”
enable.auto.commit” -> (true: java.lang.Boolean) 可以儲存offset,可以讀取錯過消息。(即使沒有checkpoint)
不開自動送出的話 offset取決于 auto.offset.reset”
0.9以後offset已經和zk沒關系
取決于 enable.auto.commit”
enable.auto.commit” -> (true: java.lang.Boolean) 可以儲存offset,可以讀取錯過消息。(即使沒有checkpoint)
不開自動送出的話 offset取決于 auto.offset.reset”
0.9以後offset已經和zk沒關系