avro sink

需要配置的：type = avro

hostname = 主机名

port = 端口

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

==a1.sources.r1.type = avro
a1.sources.r1.bind = 192.168.1.122
a1.sources.r1.port = 55555==

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

a1.sinks.k1.type = logger

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

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

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

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

==a1.sinks.k1.type = avro
a1.sinks.k1.hostname = 192.168.1.123
a1.sinks.k1.port = 55555
a1.sinks.k2.type = avro
==a1.sinks.k2.hostname = 192.168.1.124
a1.sinks.k2.port = 55555

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