kafka sink

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

a1.sources.r1.type = netcat
a1.sources.r1.bind = master
a1.sources.r1.port = 44444

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

==a1.sinks.k1.type = org.apache.flume.kafka.KafkaSink
a1.sinks.k1.kafka.bootstrap.server = master
a1.sinks.k1.kafka.topic = hkjcpdd==

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

flume监听nginx的access.log文件给kafka消费

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

a1.sources.r1.type = taildir
a1.sources.r1.filegroups = f1
a1.sources.r1.filegroups.f1 = /usr/local/nginx/logs/access.log

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

a1.sinks.k1.type = org.apache.flume.sink.kafka.KafkaSink
a1.sinks.k1.kafka.bootstrap.servers = master:9092
a1.sinks.k1.kafka.topic=hkjcpdd

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