报错

21:52:36.622 [main] DEBUG org.apache.flume.api.NettyAvroRpcClient - Batch size string = null

21:52:36.622 [main] WARN org.apache.flume.api.NettyAvroRpcClient - Using default maxIOWorkers
21:52:36.653 [main] DEBUG org.apache.avro.ipc.NettyTransceiver - Using Netty bootstrap options: {tcpNoDelay=true, connectTimeoutMillis=20000}
21:52:36.653 [main] DEBUG org.apache.avro.ipc.NettyTransceiver - Connecting to /192.168.1.101:4444
21:52:36.654 [main] DEBUG org.apache.avro.ipc.NettyTransceiver - [id: 0x15681dfd] OPEN
21:52:36.656 [New I/O worker #10] DEBUG org.apache.avro.ipc.NettyTransceiver - [id: 0x15681dfd, /192.168.1.101:49235 => /192.168.1.101:4444] BOUND: /192.168.1.101:49235
21:52:36.656 [New I/O worker #10] DEBUG org.apache.avro.ipc.NettyTransceiver - [id: 0x15681dfd, /192.168.1.101:49235 => /192.168.1.101:4444] CONNECTED: /192.168.1.101:4444
21:52:36.660 [New I/O worker #10] DEBUG org.apache.avro.ipc.NettyTransceiver - [id: 0x15681dfd, /192.168.1.101:49235 :> /192.168.1.101:4444] DISCONNECTED
21:52:36.660 [New I/O worker #10] DEBUG org.apache.avro.ipc.NettyTransceiver - [id: 0x15681dfd, /192.168.1.101:49235 :> /192.168.1.101:4444] UNBOUND
21:52:36.660 [New I/O worker #10] DEBUG org.apache.avro.ipc.NettyTransceiver - [id: 0x15681dfd, /192.168.1.101:49235 :> /192.168.1.101:4444] CLOSED
21:52:36.660 [New I/O worker #10] DEBUG org.apache.avro.ipc.NettyTransceiver - Remote peer /192.168.1.101:4444 closed connection.
21:52:36.660 [New I/O worker #10] DEBUG org.apache.avro.ipc.NettyTransceiver - Disconnecting from /192.168.1.101:4444
21:52:36.660 [New I/O worker #10] DEBUG org.apache.avro.ipc.NettyTransceiver - Removing 1 pending request(s).
log4j:ERROR Flume append() failed.

解决

更改 F:\apache-flume-1.7.0-bin\conf\example.conf

#a1.sources.r1.type = netcat
a1.sources.r1.type = avro