The InfluxDB sink connector pulls messages from Pulsar topics and persists the messages to InfluxDB.
The configuration of the InfluxDB sink connector has the following properties.
Name | Type | Required | Default | Description |
---|---|---|---|---|
influxdbUrl | String | true | " " (empty string) | The URL of the InfluxDB instance. |
username | String | false | " " (empty string) | The username used to authenticate to InfluxDB. |
password | String | false | " " (empty string) | The password used to authenticate to InfluxDB. |
database | String | true | " " (empty string) | The InfluxDB to which write messages. |
consistencyLevel | String | false | ONE | The consistency level for writing data to InfluxDB. Below are the available options:ALL ANY ONE QUORUM |
logLevel | String | false | NONE | The log level for InfluxDB request and response. Below are the available options:NONE BASIC HEADERS FULL |
retentionPolicy | String | false | autogen | The retention policy for InfluxDB. |
gzipEnable | boolean | false | false | Whether to enable gzip or not. |
batchTimeMs | long | false | 1000L | The InfluxDB operation time in milliseconds. |
batchSize | int | false | 200 | The batch size of writing to InfluxDB. |
Before using the InfluxDB sink connector, you need to create a configuration file through one of the following methods.
JSON
{ "influxdbUrl": "http://localhost:8086", "database": "test_db", "consistencyLevel": "ONE", "logLevel": "NONE", "retentionPolicy": "autogen", "gzipEnable": false, "batchTimeMs": 1000, "batchSize": 100 }
YAML
{ influxdbUrl: "http://localhost:8086" database: "test_db" consistencyLevel": "ONE" logLevel: "NONE" retentionPolicy: "autogen" gzipEnable: false batchTimeMs: 1000 batchSize: 100 }