2015-08-16 32 views
0

我使用了flume spool DIR源和KAFKA通道,但是當我嘗試從KAFKA讀取數據時發現了一個奇怪的事情:隨機字符被添加到某些字符串的前面線。flume spoolDir + kafka通道得到了編碼錯誤

\10:22:40 53311312321 是的線程否否 ..... s15:22:30 15233223213 颯颯汝非 .... 13:22:30 15233223213 颯颯事情非 ....

編碼爲U THF-8。 我認爲這個問題是關於中文字的,用4位寫一個。 有人知道嗎?

回答

-1

我們遇到了同樣的情況,使用exec源和kafka頻道。

條件似乎被校正,當我們在通道配置設置

parseAsFlumeEvent = true 

Kafka_flume