flume configuration to setup kafka as source and HDFS as sink.
tier1.channels = kafkachannel tier1.sink = hdfssink tier1.channels.kafkachannel.type = org.apache.flume.channel.kafka.KafkaChannel tier1.channels.kafkachannel.brokerList = kafkabroker-1:9092,kafkabroker-2:9092 tier1.channels.kafkachannel.topic = logs tier1.channels.kafkachannel.zookeeperConnect = kafkabroker-1:2181 tier1.channels.kafkachannel.parseAsFlumeEvent = false tier1.sinks.hdfssink.type = hdfs tier1.sinks.hdfssink.hdfs.path = /tmp/logs tier1.sinks.hdfssink.hdfs.rollinterval = 5 tier1.sinks.hdfssink.hdfs.fileType = DataStream tier1.sinks.hdfssink.channel = kafkachannel
No comments:
Post a Comment