Connect manager API Reference

connect_manager.influxdb_sink Module

Functions

update_influxdb_sink_config(config, topics) Update the InfluxDB connector configuration, adding a list of topics and the corresponding InfluxDB KCQL queries.
make_influxdb_sink_config(influxdb_url, …) Make InfluxDB Sink connector configuration.

connect_manager.main Module

connect_manager.utils Module

Functions

get_broker_url(ctx) Get the broker connection string from the context, or print an error message otherwise.
get_kafka_connect_url(ctx) Get the Confluent Kafka Connect connection string from the context, or print an error message otherwise.
get_topics(broker_url, filter_regex, blacklist) Get existing topics in Kafka.
update_connector(kafka_connect_url, name, config) Update a connector configuration.
get_connector_status(kafka_connect_url, name) Get connector status.