Kafka API的完整实现
esque-wire的Python项目详细描述
钢丝绳
kafka wire协议的完整和面向用户的实现。在
特点
支持所有Api终结点
因为API端点的代码是自动生成的,所以这个库支持其中的all。 如果出现新的代码,它的实现只需执行一次代码。此外,还提取了现场文件 如果有卡夫卡源代码的话。在
类型批注
一切都有注解!享受自动完成到最后一个字段。在
# run with mypyfromesque_wireimportBrokerConnection,ApiVersionsRequestDatarequest_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*'
- 项目
标签: