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

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 在若依框架下实现人脸识别
  • ¥15 网络科学导论,网络控制
  • ¥100 安卓tv程序连接SQLSERVER2008问题
  • ¥15 利用Sentinel-2和Landsat8做一个水库的长时序NDVI的对比,为什么Snetinel-2计算的结果最小值特别小,而Lansat8就很平均
  • ¥15 metadata提取的PDF元数据,如何转换为一个Excel
  • ¥15 关于arduino编程toCharArray()函数的使用
  • ¥100 vc++混合CEF采用CLR方式编译报错
  • ¥15 coze 的插件输入飞书多维表格 app_token 后一直显示错误,如何解决?
  • ¥15 vite+vue3+plyr播放本地public文件夹下视频无法加载