Flink InfluxDB Connector

This connector provides a sink that can send data to InfluxDB. To use this connector, add the following dependency to your project:

<dependency>
  <groupId>org.apache.bahir</groupId>
  <artifactId>flink-connector-influxdb_2.11</artifactId>
  <version>1.1-SNAPSHOT</version>
</dependency>

Version Compatibility: This module is compatible with InfluxDB 1.3.x
Requirements: Java 1.8+

Note that the streaming connectors are not part of the binary distribution of Flink. You need to link them into your job jar for cluster execution. See how to link with them for cluster execution here.

Installing InfluxDB

Follow the instructions from the InfluxDB download page.

Examples

JAVA API

DataStream<InfluxDBPoint> dataStream = ...
InfluxDBConfig influxDBConfig = InfluxDBConfig.builder(String host, String username, String password, String dbName)
dataStream.addSink(new InfluxDBSink(influxDBConfig));

See end-to-end examples at InfluxDB Examples