Skip to main content

A complete implementation of the Kafka API

Project description

pypi Version Python Versions Build Status Coverage Status License: MIT


A complete and user oriented implementation of the kafka wire protocol.


Supports all Api endpoints

Since the code for the API endpoints is automatically generated, this library supports all of them. If a new one comes along, its implementation is just one code execution away. Also the field documentation is extracted from Kafka source code if there is one.

Type annotations

Everything is annotated! Enjoy autocomplete all the way to the last field.

# run with mypy
from esque_wire import BrokerConnection, ApiVersionsRequestData

request_data = ApiVersionsRequestData()
connection = BrokerConnection("localhost:9092", "test_client")
response = connection.send(request_data)
reveal_type(response)  # Revealed type is '... AnsweredApiCall[... ApiVersionsRequestData, ... ApiVersionsResponseData]'
reveal_type(response.response_data)  # Revealed type is '... ApiVersionsResponseData*'

Project details

Release history Release notifications

Download files

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

Files for esque-wire, version 0.1.0
Filename, size File type Python version Upload date Hashes
Filename, size esque_wire-0.1.0-py3-none-any.whl (161.0 kB) File type Wheel Python version py3 Upload date Hashes View hashes
Filename, size esque-wire-0.1.0.tar.gz (60.3 kB) File type Source Python version None Upload date Hashes View hashes

Supported by

Elastic Elastic Search Pingdom Pingdom Monitoring Google Google BigQuery Sentry Sentry Error logging AWS AWS Cloud computing DataDog DataDog Monitoring Fastly Fastly CDN SignalFx SignalFx Supporter DigiCert DigiCert EV certificate StatusPage StatusPage Status page