赞
踩
即将flume作为kafka的消费者,kafka后面对接flume。
flume从kfaka里面读取数据。
配置文件如下:
a1.sources = r1
a1.channels = c1
a1.sinks = k1
a1.sources.r1.type = org.apache.flume.source.kafka.KafkaSource
a1.sources.r1.kafka.bootstrap.servers = node01:9092,node02:9092,node03:9092
a1.sources.r1.kafka.topics = kafkasource
a1.sources.r1.kafka.consumer.group.id = flume
a1.sources.r1.useFlumeEventFormat = false
a1.channels.c1.type
赞
踩
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。