sudevdev

KafkaConsumer

Dec 9th, 2015
157
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.96 KB | None | 0 0
  1. # Read from Kafka and write to file_roll
  2.  
  3. # Overall configuration
  4. kafkaconsumer.sources = kafka-source1
  5. kafkaconsumer.sinks = file-roll1
  6. kafkaconsumer.channels = channel1
  7.  
  8. # Source Kafka
  9. kafkaconsumer.sources.kafka-source1.type = org.apache.flume.source.kafka.KafkaSource
  10. kafkaconsumer.sources.kafka-source1.zookeeperConnect = dp4548:2181
  11. kafkaconsumer.sources.kafka-source1.topic = logtail
  12. kafkaconsumer.sources.kafka-source1.groupId = flume
  13. kafkaconsumer.sources.kafka-source1.channels = channel1
  14.  
  15. # Sink
  16. kafkaconsumer.sinks.file-roll1.type = file_roll
  17. kafkaconsumer.sinks.file-roll1.sink.directory = /home/flume/fileroll
  18. kafkaconsumer.sinks.file-roll1.channel = channel1
  19.  
  20. # Channel
  21. kafkaconsumer.channels.channel1.type = memory
  22. kafkaconsumer.channels.channel1.capacity = 10000
  23. kafkaconsumer.channels.channel1.transactionCapacity = 10000
  24. kafkaconsumer.channels.channel1.byteCapacityBufferPercentage = 20
  25. kafkaconsumer.channels.channel1.byteCapacity = 800000
Advertisement
Add Comment
Please, Sign In to add comment