Flume source connector

The Flume source connector pulls messages from logs to Pulsar topics.

Configuration

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

Name	Type	Required	Default	Description
`name`	String	true	"" (empty string)	The name of the agent.
`confFile`	String	true	"" (empty string)	The configuration file.
`noReloadConf`	Boolean	false	false	Whether to reload configuration file if changed.
`zkConnString`	String	true	"" (empty string)	The ZooKeeper connection.
`zkBasePath`	String	true	"" (empty string)	The base path in ZooKeeper for agent configuration.

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

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

JSON

{
    "name": "a1",
    "confFile": "source.conf",
    "noReloadConf": "false",
    "zkConnString": "",
    "zkBasePath": ""
}

YAML

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