關於kafka從新消費數據問題

咱們在使用consumer消費數據時,有些狀況下咱們須要對已經消費過的數據進行從新消費,這裏介紹kafka中兩種從新消費數據的方法。html   1. 修改offsetspa 咱們在使用consumer消費的時候,每一個topic會產生一個偏移量,這個偏移量保證咱們消費的消息順序且不重複。Offest是在zookeeper中存儲的,咱們能夠設置consumer實時或定時的註冊offest到zook
相關文章
相關標籤/搜索