Flume的netcat 监听端口

netcat agent

配置文件如下

a1.sources = r1 

a1.channels = c1 

a1.sinks = k1

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.sinks.k1.type = logger

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

测试方法:telnet localhost 44444