Flume sink connector
The Flume sink connector pulls messages from Pulsar topics to logs.
Configuration
The configuration of the Flume sink 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 sink connector, you need to create a configuration file through one of the following methods.
For more information about the
sink.confin the example below, see here.
-
JSON
{"name": "a1","confFile": "sink.conf","noReloadConf": "false","zkConnString": "","zkBasePath": ""} -
YAML
configs:name: a1confFile: sink.confnoReloadConf: falsezkConnString: ""zkBasePath: ""