update_influxdb_sink_config

connect_manager.influxdb_sink.update_influxdb_sink_config(config, topics, timestamp='')

Update the InfluxDB connector configuration, adding a list of topics and the corresponding InfluxDB KCQL queries. We assume that the topic structure is flat, i.e SELECT * FROM will retrieve the topic fields.

Parameters:
config : dict

A configuration dictionary as retuned by make_influxdb_sink_config()

topics : list

List of kafka topics.

timestamp : str

Use timestamp as the the InfluxDB timestamp.