The InfluxDB sink connector pulls messages from Pulsar topics and persists the messages to InfluxDB. The InfluxDB sink provides different configurations for InfluxDBv1 and v2 respectively.

​

Configuration

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

​

Property

​

InfluxDBv2

​

InfluxDBv1

​

Example

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

​

InfluxDBv2

• JSON
  {
      "influxdbUrl": "http://localhost:9999",
      "organization": "example-org",
      "bucket": "example-bucket",
      "token": "xxxx",
      "precision": "ns",
      "logLevel": "NONE",
      "gzipEnable": false,
      "batchTimeMs": 1000,
      "batchSize": 100
  }
  
• YAML
  {
      influxdbUrl: "http://localhost:9999"
      organization: "example-org"
      bucket: "example-bucket"
      token: "xxxx"
      precision: "ns"
      logLevel: "NONE"
      gzipEnable: false
      batchTimeMs: 1000
      batchSize: 100
  }
  

​

InfluxDBv1

• 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
  }