Kafkit API reference¶
kafkit.registry Package¶
Classes¶
Deserializer(*, registry) |
An Avro message deserializer that understands the Confluent Wire Format and obtains schemas on-demand from a Confluent Schema Registry. |
PolySerializer(*, registry) |
An Avro message serializer that can write messages for multiple schemas in the Confluent Wire Format. |
RegistryBadRequestError(status_code, *args) |
An exception if the request is invalid (4XX errors). |
RegistryBrokenError(status_code, *args[, …]) |
An excpetion if the server is down (5XX errors). |
RegistryError |
Base exception for Registry errors. |
RegistryHttpError(status_code, *args[, …]) |
A base exception that includes metadata about the HTTP response. |
RegistryRedirectionError(status_code, *args) |
An exception for 3XX responses. |
Serializer(*, schema, schema_id) |
An Avro message serializer that writes in the Confluent Wire Format. |
kafkit.registry.aiohttp Module¶
Classes¶
RegistryApi(*, session, url) |
A Confluent Schema Registry client that uses aiohttp. |
kafkit.registry.sansio Module¶
Functions¶
make_headers() |
Make HTTP headers for the Confluent Schema Registry. |
decipher_response(status_code, headers, body) |
Process a response. |
decode_body(content_type, body) |
Decode an HTTP body based on the specified content type. |
Classes¶
RegistryApi(*, url) |
A baseclass for Confluent Schema Registry clients. |
MockRegistryApi([url, status_code, headers, …]) |
A mock implementation of the RegistryApi client that doensn’t do network operations and provides attributes for introspection. |
SchemaCache() |
A cache of schemas that maintains a mapping of schemas and their IDs in a Schema Registry. |
SubjectCache(schema_cache) |
A cache of subjects in a schema registry that maps subject and version tuples to an actual schema. |