小木希望学园 2018-07-21 14:46 采纳率: 100%
浏览 2672
已采纳

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条回答

  • devmiao 2018-07-21 15:40
    关注
    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

悬赏问题

  • ¥15 求差集那个函数有问题,有无佬可以解决
  • ¥15 【提问】基于Invest的水源涵养
  • ¥20 微信网友居然可以通过vx号找到我绑的手机号
  • ¥15 寻一个支付宝扫码远程授权登录的软件助手app
  • ¥15 解riccati方程组
  • ¥15 display:none;样式在嵌套结构中的已设置了display样式的元素上不起作用?
  • ¥15 使用rabbitMQ 消息队列作为url源进行多线程爬取时,总有几个url没有处理的问题。
  • ¥15 Ubuntu在安装序列比对软件STAR时出现报错如何解决
  • ¥50 树莓派安卓APK系统签名
  • ¥65 汇编语言除法溢出问题