我正在使用flume spool DIR源和KAFKA通道,但当我尝试从KAFKA读取数据时,我发现了一件奇怪的事情:在一些字符串行的前面添加了一个随机字符。
\10:22:40 53311312321 是的线程否否 ..... s15:22:30 15233223213 飒飒汝非 .... 13:22:30 15233223213 飒飒事情非 ....
编码是U T F-8。我认为问题是关于汉字,它使用4位来写一个。有人知道这件事吗?
发布于 2015-09-29 04:06:54
我们在使用exec源和kafka通道时也遇到了同样的情况。
当我们设置时,情况似乎已得到纠正
parseAsFlumeEvent = true在通道配置中。
Kafka_flume
https://stackoverflow.com/questions/32033414
复制相似问题