我使用flume spool dir source和kafka channel，但是当我尝试从kafka读取数据时发现了一件奇怪的事情：在一些字符串行的前面添加了一个随机字符。 \10:22:40 53311312321 是的线程否否 ..... s15:22:30 15233223213 飒飒汝非 .... 13:22:30 15233223213 飒飒事情非 .... 编码是utf-8。我认为这个问题是关于汉字的，它用4位来写一个。有人知道吗？
我使用flume spool dir source和kafka channel，但是当我尝试从kafka读取数据时发现了一件奇怪的事情：在一些字符串行的前面添加了一个随机字符。 \10:22:40 53311312321 是的线程否否 ..... s15:22:30 15233223213 飒飒汝非 .... 13:22:30 15233223213 飒飒事情非 .... 编码是utf-8。我认为这个问题是关于汉字的，它用4位来写一个。有人知道吗？
1条答案
按热度按时间k10s72fa1#
我们在使用exec源和kafka通道时遇到了同样的情况。
我们设置时，情况似乎已得到纠正
在通道配置中。
Kafka渡槽