Flume和kafka连接的问题

本人使用flume1.60版本和kafka0.8.2.2版本进行连接,配置如下:
a0.sources.r1.type = xiaomu.flume.source.TailFileSource
a0.sources.r1.filePath = /root/access2.txt
a0.sources.r1.posiFile = /root/posi2.txt
a0.sources.r1.interval = 2000
a0.sources.r1.charset = UTF-8

a0.channels.c1.type = org.apache.flume.channel.kafka.KafkaChannel
a0.channels.c1.capacity = 1000
a0.channels.c1.transactionCapacity = 1000
a0.channels.c1.brokerList=slave1:9092,slave4:9092,slave3:9092
a0.channels.c1.topic=usertest3
a0.channels.c1.zookeeperConnect=slave2:2181,slave5:2181,slave6:2181
a0.channels.c1.parseAsFlumeEvent = false

但是我echo "xxx" >> access2.txt之后,在kafka那边就不一样了,比如我打xiaomu,就会出来两行,一行是xiaomum,第二行是空白,还有时候是一行但是开头有一个方框,如图所示:
图片说明

这个怎么解决呀?求助各位大神了!

1个回答

u013631121
牟天蔚 换成新版本,成功解决问题!
接近 2 年之前 回复
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
立即提问
相关内容推荐