This flume sink is intended to send the events over a TCP connection.
$ mvn package
Copy flume-tcp-sink-.jar in target folder into flume plugins dir folder
$ mkdir -p $FLUME_HOME/plugins.d/tcp-sink/lib
$ cp flume-ng-sql-source-0.0.3.jar $FLUME_HOME/plugins.d/sql-source/lib
| Property name | Default value | Description |
|---|---|---|
| hostname | - | The hostname or IP address to connect to |
| port | - | The port number of remote host to connect |
| batchSize | 100 | Number of events to be written per txn |
| connectionTimeout | 10 | Seconds to wait to stablish the connection |
| connectionRetries | 0 | How much retries to open the TCP connectionthe when some error happens (0 means no limit) |
| connectionRetryDelay | 10 | Seconds to wait before new connection retry |
a1.channels = c1
a1.sinks = k1
a1.sinks.k1.type = org.keedio.flume.sink.TcpSink
a1.sinks.k1.hostname = 127.0.0.1
a1.sinks.k1.port = 5140