具体步骤：

1. Ctrl+C关闭node3上的flume,并将/opt/flume-1.9.0拷贝到node1的/opt目录下

   xxxxxxxxxx
   [root@node3 ~]# scp -r /opt/flume-1.9.0/ node1:/opt
   

2. node1上配置环境变量，并使之生效

   xxxxxxxxxx
   [root@node1 ~]# vim /etc/profile
   # flume环境变量
   export FLUME_HOME=/opt/flume-1.9.0
   export PATH=$PATH:$FLUME_HOME/bin
   [root@node1 conf]# source /etc/profile
   

3. 在node1上复制netcat-logger.conf为netcat-avro.conf。

xxxxxxxxxx
[root@node1 jobs]# cp netcat-logger.conf netcat-avro.conf

4. node1上修改配置文件netcat-avro.conf

xxxxxxxxxx
[root@node1 jobs]# vim netcat-avro.conf
a1.sources.r1.bind = node3
# Describe the sink
a1.sinks.k1.type = logger

改为：

xxxxxxxxxx

# 将监听的node3改为node1
a1.sources.r1.bind = node1
# Describe the sink
a1.sinks.k1.type = avro
a1.sinks.k1.hostname = node3 
a1.sinks.k1.port = 10086

5. 在node3上复制netcat-logger.conf为avro-logger.conf。

   xxxxxxxxxx
   [root@node3 jobs]# cp netcat-logger.conf avro-logger.conf
   

6. node3上修改配置文件avro-logger.conf

   xxxxxxxxxx
   # Describe/configure the source
   a1.sources.r1.type = netcat
   a1.sources.r1.bind = node3
   a1.sources.r1.port = 44444
   

   改为:

   xxxxxxxxxx
   # Describe/configure the source
   a1.sources.r1.type = avro
   a1.sources.r1.bind = node3
   a1.sources.r1.port = 10086
   

7. 启动node3上的flume(由于node1发送给node3所以先启动node3)

   xxxxxxxxxx
   [root@node3 jobs]# flume-ng agent -c ./ -n a1 -f avro-logger.conf -Dflume.root.logger=INFO,console
   

8. 复制一个node3的终端查看端口10086占用情况

   xxxxxxxxxx
   [root@node3 ~]# ss -nal
   

9. 启动node1上的flume(由于node1发送给node3所以后启动node1)

   xxxxxxxxxx
   [root@node1 jobs]# flume-ng agent -c ./ -n a1 -f netcat-avro.conf -Dflume.root.logger=INFO,console
   

10. node2上发消息给node1

    xxxxxxxxxx
    [root@node2 ~]# yum install -y telnet
    [root@node2 ~]# telnet node1 44444
    Trying 192.168.20.101...
    Connected to node1.
    Escape character is '^]'.
    a
    OK
    b
    OK
    c
    OK
    

11. node1上没有显示信息，而是node3上显示信息，这是因为node1接收到消息后，传递给了node3

    xxxxxxxxxx
    Event: { headers:{} body: 61 0D a. }
    Event: { headers:{} body: 62 0D b. }
    Event: { headers:{} body: 63 0D c. }