sink
Flume Sink
The Flume sink connector pulls messages from Pulsar topics to logs
Authored by
ASF
Support type
StreamNative
License
Apache License 2.0

Configuration

The configuration of the Flume sink connector has the following properties.

Property

NameTypeRequiredDefaultDescription
nameStringtrue"" (empty string)The name of the agent.
confFileStringtrue"" (empty string)The configuration file.
noReloadConfBooleanfalsefalseWhether to reload configuration file if changed.
zkConnStringStringtrue"" (empty string)The ZooKeeper connection.
zkBasePathStringtrue"" (empty string)The base path in ZooKeeper for agent configuration.

Example

Before using the Flume sink connector, you need to create a configuration file through one of the following methods.

For more information about the sink.conf in the example below, see here.

  • JSON

    {
        "name": "a1",
        "confFile": "sink.conf",
        "noReloadConf": "false",
        "zkConnString": "",
        "zkBasePath": ""
    }
    
  • YAML

    configs:
        name: a1
        confFile: sink.conf
        noReloadConf: false
        zkConnString: ""
        zkBasePath: ""