RegistryApi

class kafkit.registry.aiohttp.RegistryApi(*, session, url)

Bases: RegistryApi

A Confluent Schema Registry client that uses aiohttp.

Parameters:

• session (aiohttp.ClientSession) – An aiohttp client session.

• url (str) – The Confluent Schema Registry URL (e.g. http://registry:8081).