Flume NG Fluentd Sink

Apache Flume Sink plugin for Fluentd.

Configuration

For Apache Flume

Set configuration properties like this:

a1.sinks = k1

a1.sinks.k1.type = com.github.cosmo0920.fluentd.flume.plugins.FluentdSink
al.sinks.k1.hostname = localhost
a1.sinks.k1.port = 24224
a1.sinks.k1.tag = flume.fluentd.sink
a1.sinks.k1.format = text
# for file backup (not mandatory but recommended)
# a1.sinks.k1.backupDir = /tmp/flume-ng-fluentd-sink

hostname, port, and tag are optional.

You can pass text or json into format.

Please refer to example single flume node example for in more detail usage.

For Fluentd

Set configuration properties like this:

<source>
  type forward
  bind 0.0.0.0
  port 24224
</source>

bind and port are optional.

How to use

Create all-in-one jar file.

$ ./gradlew shadowJar

Put created all-in-one jar file into your $FLUME_HOME/lib.

LICENSE

• Apache-2.0