1. 程式人生 > >用java測試flume無法得到結果的可能原因

用java測試flume無法得到結果的可能原因

我在用java api 批量產生資料通過socket傳送到agent後,發現目標日誌沒有我傳送的字串,並且日誌中沒有任何異常.在多次嘗試和詢問朋友後,我瞭解到,source監控tcp的資料流時,是按照行讀的,也就是說,當資料流中的內容換行時source才會執行讀取操作.

故,應該在傳送的字串末尾加上換行符,或者使用PrintStream的println方法自動換行.