############
kafkaconnect
############
|Build| |Docker|
A Python client for managing connectors using the `Kafka Connect API <https://docs.confluent.io/current/connect/references/restapi.html>`_.
See `the docs <https://kafka-connect-manager.lsst.io>`_ for more information.
.. |Build| image:: https://github.com/lsst-sqre/kafka-connect-manager/workflows/CI/badge.svg
:alt: GitHub Actions
:scale: 100%
:target: https://github.com/lsst-sqre/kafka-connect-manager/actions
.. |Docker| image:: https://img.shields.io/docker/v/lsstsqre/kafkaconnect?sort=date
:alt: Docker Hub repository
:scale: 100%
:target: https://hub.docker.com/repository/docker/lsstsqre/kafkaconnect
##########
Change log
##########
1.3.1 (2023-07-03)
==================
* Add the --remove-prefix option to rename measurements in the InfluxDB Sink connector
1.2.0 (2023-06-12)
==================
* Add support to Strimzi Kafka 0.35.1 and Kafka 3.4.0
1.1.0 (2023-05-28)
==================
* Add support to tags in the InfluxDB Sink connector
* Add support to Strimzi Kafka 0.34.0 and Kafka 3.3.1
1.0.2 (2023-01-13)
==================
* Add support to Strimzi Kafka 0.32.0 and Kafka 3.3.1.
1.0.0 (2022-07-09)
==================
* Add support to Strimzi Kafka 0.29.0 and Kafka 3.1.1.
* Build Strimzi Kafka image with a special version of the InfluxDB Sink connector plugin which supports timestamps in microseconds.
* Build Strimzi Kafka image with Kafka Connect Avro Converter plugin.
* New class TopicNamesSet
* Add SASL authentication to Kafka brokers
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 <https://github.com/lensesio/stream-reactor/issues/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.
Raw data
{
"_id": null,
"home_page": "https://github.com/lsst-sqre/kafka-connect-manager",
"name": "kafkaconnect",
"maintainer": "",
"docs_url": null,
"requires_python": ">=3.11",
"maintainer_email": "",
"keywords": "lsst",
"author": "Association of Universities for Research in Astronomy, Inc. (AURA)",
"author_email": "sqre-admin@lists.lsst.org",
"download_url": "https://files.pythonhosted.org/packages/8d/1f/2ef326db1cac380b630d0c46ccd8a8b4db59fa9fc735a00c5dad0db0d611/kafkaconnect-1.3.1.tar.gz",
"platform": null,
"description": "############\nkafkaconnect\n############\n\n|Build| |Docker|\n\nA Python client for managing connectors using the `Kafka Connect API <https://docs.confluent.io/current/connect/references/restapi.html>`_.\n\nSee `the docs <https://kafka-connect-manager.lsst.io>`_ for more information.\n\n\n.. |Build| image:: https://github.com/lsst-sqre/kafka-connect-manager/workflows/CI/badge.svg\n :alt: GitHub Actions\n :scale: 100%\n :target: https://github.com/lsst-sqre/kafka-connect-manager/actions\n\n.. |Docker| image:: https://img.shields.io/docker/v/lsstsqre/kafkaconnect?sort=date\n :alt: Docker Hub repository\n :scale: 100%\n :target: https://hub.docker.com/repository/docker/lsstsqre/kafkaconnect\n\n##########\nChange log\n##########\n\n1.3.1 (2023-07-03)\n==================\n\n* Add the --remove-prefix option to rename measurements in the InfluxDB Sink connector\n\n1.2.0 (2023-06-12)\n==================\n\n* Add support to Strimzi Kafka 0.35.1 and Kafka 3.4.0\n\n1.1.0 (2023-05-28)\n==================\n\n* Add support to tags in the InfluxDB Sink connector\n* Add support to Strimzi Kafka 0.34.0 and Kafka 3.3.1\n\n1.0.2 (2023-01-13)\n==================\n\n* Add support to Strimzi Kafka 0.32.0 and Kafka 3.3.1.\n\n1.0.0 (2022-07-09)\n==================\n\n* Add support to Strimzi Kafka 0.29.0 and Kafka 3.1.1.\n* Build Strimzi Kafka image with a special version of the InfluxDB Sink connector plugin which supports timestamps in microseconds.\n* Build Strimzi Kafka image with Kafka Connect Avro Converter plugin.\n* New class TopicNamesSet\n* Add SASL authentication to Kafka brokers\n\n0.9.3 (2021-10-29)\n==================\n\n* Refactor S3 Sink connector, it now expects a configuration file which is templated in the Helm chart.\n* Updated docs.\n\n0.9.1 (2021-06-09)\n==================\n\n* Add support to configure multiple InfluxDB Sink connectors.\n* Add user guide documentation on how to reset the InfluxDB Sink connector consumer group offsets.\n* Update ``cp-kafka-connect`` image with new version of the InfluxDB Sink Connector. See `#737 <https://github.com/lensesio/stream-reactor/issues/737>`_ for details.\n\n0.9.0 (2021-05-03)\n==================\n\n* Add ``create mirrormaker2`` command\n* Add ``create jdbc-sink`` command\n* Update dependencies\n\n\n0.8.3 (2021-03-04)\n==================\n\n* Add upload command\n* Initial support to MirrorMaker 2 and Confuent JDBC Sink Connectors\n* Update dependencies\n\n0.8.2 (2021-01-25)\n==================\n\n* 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.\n* Reorganize developer and user guides.\n* Add documentation in the user guide on how to run the InfluxDB Sink connector locally.\n* Update dependencies\n\n0.8.1 (2020-10-18)\n==================\n\n* Fix bug preventing to read InfluxDB password from the environment\n* Update ``cp-kafka-connect`` image with Confluent Platform 5.5.2\n* Update dependencies\n\n0.8.0 (2020-08-05)\n==================\n\n* Use data classes for the application and connector configuration.\n* Plugin like organization, to support new connectors add a cli and a config file.\n* Add support to the Amazon S3 Sink connector\n\n0.7.2 (2020-03-31)\n==================\n\n* Add support to the InfluxDB Sink Connector.\n* Add --timestamp option to select the timestamp field to use in the InfluxDB Sink connector.\n* Fix Header Converter Class configuration setting.\n* Fix ``tasks.max`` configuration setting name.\n* Add connector ``name`` configuration setting to support multiple connectors of the same class.\n* Handle empty list of topics properly.\n\nMIT License\n\nCopyright 2020 Association of Universities for Research in Astronomy, Inc. (AURA)\n\nPermission is hereby granted, free of charge, to any person obtaining a copy\nof this software and associated documentation files (the \"Software\"), to deal\nin the Software without restriction, including without limitation the rights\nto use, copy, modify, merge, publish, distribute, sublicense, and/or sell\ncopies of the Software, and to permit persons to whom the Software is\nfurnished to do so, subject to the following conditions:\n\nThe above copyright notice and this permission notice shall be included in all\ncopies or substantial portions of the Software.\n\nTHE SOFTWARE IS PROVIDED \"AS IS\", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR\nIMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,\nFITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE\nAUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER\nLIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,\nOUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE\nSOFTWARE.\n",
"bugtrack_url": null,
"license": "",
"summary": "Python client for managing Kafka connectors.",
"version": "1.3.1",
"project_urls": {
"Change log": "https://github.com/lsst-sqre/kafka-connect-manager/blob/master/CHANGELOG.rst",
"Homepage": "https://github.com/lsst-sqre/kafka-connect-manager",
"Issue tracker": "https://github.com/lsst-sqre/kafka-connect-manager/issues",
"Source code": "https://github.com/lsst-sqre/kafka-connect-manager"
},
"split_keywords": [
"lsst"
],
"urls": [
{
"comment_text": "",
"digests": {
"blake2b_256": "5494a8b13edf525d4df06fa43f23ebf52ff47ac84b8374f763b047b981458a10",
"md5": "f447f8c9ef2df3134853018910c4f6e5",
"sha256": "ff8d7c2230cdef73a26ba2e5b33aa6ff0cae66ce53665ef4d04cafafa706164c"
},
"downloads": -1,
"filename": "kafkaconnect-1.3.1-py3-none-any.whl",
"has_sig": false,
"md5_digest": "f447f8c9ef2df3134853018910c4f6e5",
"packagetype": "bdist_wheel",
"python_version": "py3",
"requires_python": ">=3.11",
"size": 19583,
"upload_time": "2023-07-03T17:02:07",
"upload_time_iso_8601": "2023-07-03T17:02:07.949730Z",
"url": "https://files.pythonhosted.org/packages/54/94/a8b13edf525d4df06fa43f23ebf52ff47ac84b8374f763b047b981458a10/kafkaconnect-1.3.1-py3-none-any.whl",
"yanked": false,
"yanked_reason": null
},
{
"comment_text": "",
"digests": {
"blake2b_256": "8d1f2ef326db1cac380b630d0c46ccd8a8b4db59fa9fc735a00c5dad0db0d611",
"md5": "3f2754ff7050f588ac143950285231fb",
"sha256": "133b2335dc70ccf5749a29ed102adc6ee8d7cd11d5252d49434ea250991bdf82"
},
"downloads": -1,
"filename": "kafkaconnect-1.3.1.tar.gz",
"has_sig": false,
"md5_digest": "3f2754ff7050f588ac143950285231fb",
"packagetype": "sdist",
"python_version": "source",
"requires_python": ">=3.11",
"size": 85304,
"upload_time": "2023-07-03T17:02:09",
"upload_time_iso_8601": "2023-07-03T17:02:09.328218Z",
"url": "https://files.pythonhosted.org/packages/8d/1f/2ef326db1cac380b630d0c46ccd8a8b4db59fa9fc735a00c5dad0db0d611/kafkaconnect-1.3.1.tar.gz",
"yanked": false,
"yanked_reason": null
}
],
"upload_time": "2023-07-03 17:02:09",
"github": true,
"gitlab": false,
"bitbucket": false,
"codeberg": false,
"github_user": "lsst-sqre",
"github_project": "kafka-connect-manager",
"travis_ci": false,
"coveralls": false,
"github_actions": true,
"lcname": "kafkaconnect"
}
JSON
