The current connector is based on the Flink's old connector API and InfluxDB v1.X. InfluxDB's architecture change was quite an impact, hence, changes were made on both sides. Though, we are aware of the current implementation and investigate what we can reuse.
Best Leon -- Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/
