InfluxDB Source and Sink Connector for Confluent Platform

The Kafka Connect InfluxDB connectors integrate Kafka with an InfluxDB host. The package includes a source connector and a sink connector.

  • InfluxDB Source: Imports data from an InfluxDB host into a Kafka topic by periodically running an Influx query. By default, the connector copies all measurements in a database, each to its own output topic.

  • InfluxDB Sink: Writes data from a Kafka topic to an InfluxDB host. The connector combines records in a batch that share the same measurement, time, and tags.