新建一个文件 flume-config01.conf,输入下面的内容。该配置定义了一个 agent 叫做 a1,soruce 监听 4444 端口,channel 使用内存缓存,sink 用于输出日志到控制台。

    需要注意的是,sinks.k1.channel 是单数

    1. # example.conf: A single-node Flume configuration
    2. # Name the components on this agent
    3. a1.sources = r1
    4. a1.sinks = k1
    5. a1.channels = c1
    6. # Describe/configure the source
    7. a1.sources.r1.type = netcat
    8. a1.sources.r1.bind = localhost
    9. a1.sources.r1.port = 44444
    10. # Describe the sink
    11. a1.sinks.k1.type = logger
    12. # Use a channel which buffers events in memory
    13. a1.channels.c1.type = memory
    14. a1.channels.c1.capacity = 1000
    15. a1.channels.c1.transactionCapacity = 100
    16. # Bind the source and sink to the channel
    17. a1.sources.r1.channels = c1
    18. a1.sinks.k1.channel = c1

    启动命令

    1. flume-ng agent --conf conf --conf-file conf/flume-config01.conf -name a1 -Dflume.root.logger=INFO,console

    打开另一个窗口,输入

    1. telnet localhost 44444

    如图:
    截屏2021-08-12 下午2.09.07.png截屏2021-08-12 下午2.09.00.png