Filebeat通過將每次發(fā)送的數(shù)據(jù)狀態(tài)都存儲在Registry文件中來確保數(shù)據(jù)不丟失。如果發(fā)送的Output端沒有返回確認(rèn)信息,F(xiàn)ilebeat將 會繼續(xù)嘗試發(fā)送上- -次的數(shù)據(jù),直到Output端返回給Filebeat確認(rèn)接收信息為止。
當(dāng)向Output端發(fā)送數(shù)據(jù),或者還沒有接收到Output端返回的確認(rèn)信息時(shí),如Filebeat因異常退出而關(guān)閉,那么在Filebeat重啟后,將會把上一次發(fā)送的數(shù)據(jù)再發(fā)送一遍,以確保數(shù)據(jù)至少被接收一次。 所以在Output端 可能會出現(xiàn)重復(fù)的數(shù)據(jù)。我們可以通過shutdown_ timeout來設(shè) 置Filebeat關(guān)閉前等待的時(shí)間。
當(dāng)使用Kafka作為Output時(shí),如果不要求數(shù)據(jù)的完整性,則可以容忍少量的丟失數(shù)據(jù)。我們也可以通過設(shè)置required _acks參數(shù)來提高Filebeat發(fā)送數(shù)據(jù)的效率,required_ _acks默認(rèn)值為1, 表示等待Kafka接收副本返回確認(rèn)信息;設(shè)置為o,表示Kafka不返回確認(rèn)接收信息,F(xiàn)ilebeat將會持續(xù)發(fā)送; 設(shè)置為-1, 表示需要等待Kafka所有副本確認(rèn)接收信息后,才繼續(xù)發(fā)送。
當(dāng)前題目:Filebeat如何確保數(shù)據(jù)不丟失
當(dāng)前URL:http://www.rwnh.cn/news6/105006.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供靜態(tài)網(wǎng)站、電子商務(wù)、網(wǎng)站設(shè)計(jì)公司、手機(jī)網(wǎng)站建設(shè)、網(wǎng)站導(dǎo)航、企業(yè)網(wǎng)站制作
廣告
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來源:
創(chuàng)新互聯(lián)