Python client for managing Kafka connectors..
Project description
kafka-connect-manager
A Python client to configure and create connectors using the Kafka Connect API.
Overview
Kafka-connect-manager helps to configure and create Kafka connectors. It can select Kafka topics using a regular expression and exclude topics added to a exclusion list. The auto-update option dynamically updates the connector if topics are created or deleted in Kafka.
Kafka-connect-manager can validate the connector configuration and return the validation output in case of errors.
Kafka-connect-manager provides a command line interface (CLI) to interact with the Kafka Connect API. Using the CLI you can manage existing connectors or create a new one.
To deploy a supported connector, you can use the kafka-connect-manager Helm chart.
Supported connectors
See the docs for more information.
Change log
0.8.2 (2021-01-25)
Update cp-kafka-connect image with new version of the InfluxDB Sink connector. This version bumps the influxdb-java dependency from version 2.9 to 2.21. In parrticular 2.16 introduced a fix to skip fields with NaN and Infinity values when writing to InfluxDB.
Reorganize developer and user guides.
Add documentation in the user guide on how to run the InfluxDB Sink connector locally.
Update dependencies
0.8.1 (2020-10-18)
Fix bug preventing to read InfluxDB password from the environment
Update cp-kafka-connect image with Confluent Platform 5.5.2
Update dependencies
0.8.0 (2020-08-05)
Use data classes for the application and connector configuration.
Plugin like organization, to support new connectors add a cli and a config file.
Add support to the Amazon S3 Sink connector
0.7.2 (2020-03-31)
Add support to the InfluxDB Sink Connector.
Add –timestamp option to select the timestamp field to use in the InfluxDB Sink connector.
Fix Header Converter Class configuration setting.
Fix tasks.max configuration setting name.
Add connector name configuration setting to support multiple connectors of the same class.
Handle empty list of topics properly.
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Hashes for kafkaconnect-0.8.2-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 21dcb1c79d98e3895c7f996bf8808d60230c3964bad45f4fbade9f98f2cb9b6f |
|
MD5 | b7fdd6ed0bd6f7ef6729ba81af69013c |
|
BLAKE2b-256 | 22343f7e5403b2d125d881e45350a8f012dbff0e9304d641f31dfdff3999412a |