报错
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
