Skip to main content

Python client for managing Kafka connectors.

Project description

kafkaconnect

GitHub Actions Docker Hub repository

A Python client for managing connectors using the Kafka Connect API.

See the docs for more information.

Change log

0.9.3 (2021-10-29)

  • Refactor S3 Sink connector, it now expects a configuration file which is templated in the Helm chart.

  • Updated docs.

0.9.1 (2021-06-09)

  • Add support to configure multiple InfluxDB Sink connectors.

  • Add user guide documentation on how to reset the InfluxDB Sink connector consumer group offsets.

  • Update cp-kafka-connect image with new version of the InfluxDB Sink Connector. See #737 for details.

0.9.0 (2021-05-03)

  • Add create mirrormaker2 command

  • Add create jdbc-sink command

  • Update dependencies

0.8.3 (2021-03-04)

  • Add upload command

  • Initial support to MirrorMaker 2 and Confuent JDBC Sink Connectors

  • Update dependencies

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 particular 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.

MIT License

Copyright 2020 Association of Universities for Research in Astronomy, Inc. (AURA)

Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the “Software”), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions:

The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software.

THE SOFTWARE IS PROVIDED “AS IS”, WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

kafkaconnect-0.9.3.tar.gz (70.7 kB view details)

Uploaded Source

Built Distribution

kafkaconnect-0.9.3-py3-none-any.whl (18.5 kB view details)

Uploaded Python 3

File details

Details for the file kafkaconnect-0.9.3.tar.gz.

File metadata

  • Download URL: kafkaconnect-0.9.3.tar.gz
  • Upload date:
  • Size: 70.7 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/3.4.2 importlib_metadata/4.8.1 pkginfo/1.7.1 requests/2.26.0 requests-toolbelt/0.9.1 tqdm/4.62.3 CPython/3.9.7

File hashes

Hashes for kafkaconnect-0.9.3.tar.gz
Algorithm Hash digest
SHA256 25bd96ec0603e292c66e5f372b88e9b25e8fdccc05e482c49b2964a757805490
MD5 d18d3b6e93b72e20f16d2fb4ca89da7a
BLAKE2b-256 7326eee8323e50b27be05dc3e04eee48d8f56ba07c444fd6616ded6b63dc3f5c

See more details on using hashes here.

File details

Details for the file kafkaconnect-0.9.3-py3-none-any.whl.

File metadata

  • Download URL: kafkaconnect-0.9.3-py3-none-any.whl
  • Upload date:
  • Size: 18.5 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/3.4.2 importlib_metadata/4.8.1 pkginfo/1.7.1 requests/2.26.0 requests-toolbelt/0.9.1 tqdm/4.62.3 CPython/3.9.7

File hashes

Hashes for kafkaconnect-0.9.3-py3-none-any.whl
Algorithm Hash digest
SHA256 ab6ebcba2f29d02e3c90210c00082be340e15be8fe0e665f42b62aeb7ce5ac55
MD5 74d23c2f360d37042ca4bfc5a1156d06
BLAKE2b-256 b45901159c1af5ca13256f80463f2e49fac3df51ab258235afd913f7775bb0ca

See more details on using hashes here.

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page