storm acker 機制詳解

首先來看一下什麼叫做記錄級容錯?storm允許用戶在spout中發射一個新的源tuple時爲其指定一個message id, 這個message id可以是任意的object對象。多個源tuple可以共用一個message id,表示這多個源 tuple對用戶來說是同一個消息單元。storm中記錄級容錯的意思是說,storm會告知用戶每一個消息單元是否在指定時間內被完全處理了。那什麼叫做完全處理呢
相關文章
相關標籤/搜索