在Storm中，消息的保證機(jī)制是通過(guò)acknowledgement（ACK）和reliable tuple tracking來(lái)實(shí)現(xiàn)的。一旦一個(gè)spout發(fā)射一個(gè)tuple，它會(huì)等待接收到tuple的下游組件發(fā)送一個(gè)ACK，以確認(rèn)這個(gè)tuple已經(jīng)被成功處理。如果一段時(shí)間內(nèi)沒(méi)有收到ACK，Spout會(huì)重新發(fā)射這個(gè)tuple，以確保它能夠被正確處理。這種機(jī)制確保了消息在Storm拓?fù)渲械目煽總鬟f和處理。
億速云公眾號(hào)
手機(jī)網(wǎng)站二維碼
