[BAHIR-284] Support Token Authentication for InfluxDB2 connector

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: Flink-1.0
• Fix Version/s: Flink-1.1.0
• Component/s: Flink Streaming Connectors
• Assignee: João Boto
• Reporter: David Quigley
• Created: 06/Oct/21 15:09
• Updated: 23/May/23 12:20
• Resolved: 17/Jul/22 14:58

Description

The org.apache.flink.streaming.connectors.influxdb.sink.InfluxDBSinkOptions class only supports username and password for authentication. This results in basic authentication being used by the underlying com.influxdb.client.InfluxDBClient instance. If the influxdb instance restarts, the session token retrieved from the basic authentication flow expires, resulting in all subsequent writes failing.

The access token is a more durable authentication method. A token option should be added to the org.apache.flink.streaming.connectors.influxdb.sink.InfluxDBSinkOptions class.

Issue Links

• links to: GitHub Pull Request #127