The Flume source connector pulls messages from logs to Pulsar topics.
Configuration
The configuration of the Flume source connector has the following properties.
Property
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. |
Example
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: ""