flume监听文件

a3.sources=r1
a1.sinks=k1 k2
a1.channels=c1 c2

a1.sources.r1.type=netcat
a1.sources.r1.bind=localhost
a1.sources.r1.port=26001

a1.sinks.k1.type=org.apache.flume.sink.kafka.KafkaSink
a1.sinks.k1.kafka.bootstrap.servers=192.168.23.69:9092
a1.sinks.k1.kafka.topic=order
a1.sinks.k1.kafka.producer.acks=1

a1.channels.c1.type=memory
a1.channels.c1.capacity=1000
a1.channels.c1.transactionCapacity=100

a1.sources.r1.channels=c1 c2
a1.sinks.k1.channel=c1

a1.sinks.k2.type=hdfs
a1.sinks.k2.hdfs.path=hdfs://192.168.23.69:9000/user/test/flumebackup
a1.sinks.k2.hdfs.fileType=DataStream
a1.sinks.k2.hdfs.writeFormat=text
a1.sinks.k2.hdfs.rollIntervall=0
a1.sinks.k2.hdfs.rollSize=134217728
a1.sinks.k2.hdfs.rollCount=0
a1.sinks.k2.hdfs.bachSize=0
a1.sinks.k2.hdfs.useLocalTimeStamp=true

a1.channels.c2.type=memory
a1.channels.c2.capacity=1000000
a1.channels.c2.keep-alive=60

a1.sinks.k2.channel=c2

最后

以上就是有魅力星星最近收集整理的关于flume监听文件的全部内容，更多相关flume监听文件内容请搜索靠谱客的其他文章。