| Name | kafkit JSON |
| Version |
0.3.0
JSON |
| download |
| home_page | |
| Summary | Kafkit helps you write Kafka producers and consumers in Python with asyncio. |
| upload_time | 2023-02-23 23:20:33 |
| maintainer | |
| docs_url | None |
| author | |
| requires_python | >=3.8 |
| license | MIT |
| keywords |
rubin
lsst
|
| VCS |
 |
| bugtrack_url |
|
| requirements |
No requirements were recorded.
|
| Travis-CI |
No Travis.
|
| coveralls test coverage |
No coveralls.
|
# Kafkit
Kafkit helps you write Kafka producers and consumers in Python with asyncio:
- Kafkit provides a client for the Confluent Schema Registry's HTTP API.
The `RegistryApi` client includes both high-level methods for managing subjects and schemas in a Registry, and direct low-level access to HTTP methods (GET, POST, PUT, PATCH, and DELETE).
The high-level methods use caching so you can use the client as an integral part of your application's schema management.
`RegistryApi` is implemented around [aiohttp](https://aiohttp.readthedocs.io/en/stable/), but since the base class is designed with a [sans IO architecture](https://sans-io.readthedocs.io), a Registry client can be implemented with any asyncio HTTP library.
- Kafkit provides Avro message serializers and deserializers that integrate with the [Confluent Schema Registry](https://docs.confluent.io/current/schema-registry/docs/index.html): `Deserializer`, `Serializer`, and `PolySerializer`.
- The `RecordNameSchemaManager` is a streamlined tool for serializing messages using the schemas maintained by your app, while also integrating with the [Confluent Schema Registry](https://docs.confluent.io/current/schema-registry/docs/index.html).
- The `kafkit.ssl` module helps you connect to SSL-secured Kafka brokers.
Learn more about Kafkit at https://kafkit.lsst.io.
Raw data
{
"_id": null,
"home_page": "",
"name": "kafkit",
"maintainer": "",
"docs_url": null,
"requires_python": ">=3.8",
"maintainer_email": "",
"keywords": "rubin,lsst",
"author": "",
"author_email": "\"Association of Universities for Research in Astronomy, Inc. (AURA)\" <sqre-admin@lists.lsst.org>",
"download_url": "https://files.pythonhosted.org/packages/11/ea/39a31aca52ef94e3e6e7df46f71659767dfff525fe26e5d2e4b64fb3ae84/kafkit-0.3.0.tar.gz",
"platform": null,
"description": "# Kafkit\n\nKafkit helps you write Kafka producers and consumers in Python with asyncio:\n\n- Kafkit provides a client for the Confluent Schema Registry's HTTP API.\n The `RegistryApi` client includes both high-level methods for managing subjects and schemas in a Registry, and direct low-level access to HTTP methods (GET, POST, PUT, PATCH, and DELETE).\n The high-level methods use caching so you can use the client as an integral part of your application's schema management.\n `RegistryApi` is implemented around [aiohttp](https://aiohttp.readthedocs.io/en/stable/), but since the base class is designed with a [sans IO architecture](https://sans-io.readthedocs.io), a Registry client can be implemented with any asyncio HTTP library.\n\n- Kafkit provides Avro message serializers and deserializers that integrate with the [Confluent Schema Registry](https://docs.confluent.io/current/schema-registry/docs/index.html): `Deserializer`, `Serializer`, and `PolySerializer`.\n\n- The `RecordNameSchemaManager` is a streamlined tool for serializing messages using the schemas maintained by your app, while also integrating with the [Confluent Schema Registry](https://docs.confluent.io/current/schema-registry/docs/index.html).\n\n- The `kafkit.ssl` module helps you connect to SSL-secured Kafka brokers.\n\nLearn more about Kafkit at https://kafkit.lsst.io.\n",
"bugtrack_url": null,
"license": "MIT",
"summary": "Kafkit helps you write Kafka producers and consumers in Python with asyncio.",
"version": "0.3.0",
"project_urls": {
"Homepage": "https://kafkit.lsst.io",
"Source": "https://github.com/lsst-sqre/kafkit"
},
"split_keywords": [
"rubin",
"lsst"
],
"urls": [
{
"comment_text": "",
"digests": {
"blake2b_256": "e4a4f64da734f5703bda4ee0391cada4532585062a9526ba324d84fd49bef9c0",
"md5": "bd4b7861d935cd1d2814c7bcf2dd66c0",
"sha256": "9e29a861ef1156d0479b373205651b617e52aece358aff9363eb059e1dfed2cc"
},
"downloads": -1,
"filename": "kafkit-0.3.0-py3-none-any.whl",
"has_sig": false,
"md5_digest": "bd4b7861d935cd1d2814c7bcf2dd66c0",
"packagetype": "bdist_wheel",
"python_version": "py3",
"requires_python": ">=3.8",
"size": 21102,
"upload_time": "2023-02-23T23:20:31",
"upload_time_iso_8601": "2023-02-23T23:20:31.928906Z",
"url": "https://files.pythonhosted.org/packages/e4/a4/f64da734f5703bda4ee0391cada4532585062a9526ba324d84fd49bef9c0/kafkit-0.3.0-py3-none-any.whl",
"yanked": false,
"yanked_reason": null
},
{
"comment_text": "",
"digests": {
"blake2b_256": "11ea39a31aca52ef94e3e6e7df46f71659767dfff525fe26e5d2e4b64fb3ae84",
"md5": "c36cac78722e2f9a3752a4a93e708fb5",
"sha256": "9cf40f160fa75288e4a8d1df1dc084c3df48b39720866b1e5b1ec5db877bc03b"
},
"downloads": -1,
"filename": "kafkit-0.3.0.tar.gz",
"has_sig": false,
"md5_digest": "c36cac78722e2f9a3752a4a93e708fb5",
"packagetype": "sdist",
"python_version": "source",
"requires_python": ">=3.8",
"size": 46555,
"upload_time": "2023-02-23T23:20:33",
"upload_time_iso_8601": "2023-02-23T23:20:33.778761Z",
"url": "https://files.pythonhosted.org/packages/11/ea/39a31aca52ef94e3e6e7df46f71659767dfff525fe26e5d2e4b64fb3ae84/kafkit-0.3.0.tar.gz",
"yanked": false,
"yanked_reason": null
}
],
"upload_time": "2023-02-23 23:20:33",
"github": true,
"gitlab": false,
"bitbucket": false,
"codeberg": false,
"github_user": "lsst-sqre",
"github_project": "kafkit",
"travis_ci": false,
"coveralls": false,
"github_actions": true,
"tox": true,
"lcname": "kafkit"
}
