利用Eclipse对Flume进行远程调试分析环境搭建

a1.sources = r1

a1.sinks = k1

a1.channels = c1

# 配置sources

a1.sources.r1.type = netcat

a1.sources.r1.bind = localhost

a1.sources.r1.port = 6666

# 配置sink

a1.sinks.k1.type = com.flumeextend.RollingFileSink

a1.sinks.k1.sink.directory = G:\\apache-flume-1.8.0-bin\\RollingFileSinkTest

a1.sinks.k1.sink.rollInterval=0

a1.sinks.k1.sink.batchSize=100

a1.sinks.k1.sink.serializer=TEXT

a1.sinks.k1.sink.serializer.appendNewline = true

# 配置channel

a1.channels.c1.type = file

a1.channels.c1.checkpointDir = G:\\apache-flume-1.8.0-bin\\checkpoint

a1.channels.c1.dataDirs = G:\\apache-flume-1.8.0-bin\\data

# 将三者串联

a1.sources.r1.channels = c1

a1.sinks.k1.channel = c1

$JAVA_OPTS="-Xmx100m -Xdebug -Xrunjdwp:transport=dt_socket,address=8888,server=y,suspend=y"

cd G:\apache-flume-1.8.0-bin\bin

.\flume-ng.cmd agent --conf ../conf  --conf-file ../conf/RollingFileSink.conf --name a1 --property flume.root.logger=INFO,console

telnet localhost 6666