KafkaProducer

# Write to kafka

kafkaproducer.sources = tail1
kafkaproducer.sinks = kafka-sink1
kafkaproducer.channels = channel1

# Describe the source
kafkaproducer.sources.tail1.type = exec
kafkaproducer.sources.tail1.command = /usr/bin/vmstat 1


# Sink
kafkaproducer.sinks.kafka-sink1.type = org.apache.flume.sink.kafka.KafkaSink
kafkaproducer.sinks.kafka-sink1.topic = logtail
kafkaproducer.sinks.kafka-sink1.brokerList = dp4547:9092
kafkaproducer.sinks.kafka-sink1.batchSize = 20

kafkaproducer.channels.channel1.type = memory
kafkaproducer.channels.channel1.capacity = 10000
kafkaproducer.channels.channel1.transactionCapacity = 10000
kafkaproducer.channels.channel1.byteCapacityBufferPercentage = 20
kafkaproducer.channels.channel1.byteCapacity = 800000

kafkaproducer.sources.tail1.channels = channel1
kafkaproducer.sinks.kafka-sink1.channel = channel1