Kafka API的完整实现

esque-wire的Python项目详细描述


pypi VersionPython VersionsBuild StatusCoverage StatusLicense: MIT

钢丝绳

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*'

欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
我可以用C++代码使用java代码吗?   java使用JSR303在派生类中提供更具体的约束   java在这个查找唯一路径数算法中我做错了什么?   java如何为2个不同的服务提供商使用2个不同的SSL证书?   java在Gridview上绘制文本   java使用连接for循环构建字符串名   java StringBuilder拆分无法处理某些文件   java事件关注EditText   Java Web Start“找不到URL的缓存资源”   java程序从命令行运行的速度比在Eclipse中慢   java为什么HttpServletRequest会截断#字符上的url输入?   java自定义折叠工具栏平滑标题大小调整   使用Mockito对安卓 java中调用另一个静态函数的函数进行单元测试   http在java客户机中使用cachecontrol头   java如何使用。是否使用Delimiter从输入文件中排除标点符号和数字?   使用上下文作为参数/参数的java   java更有效地从Jar中提取文件   java为多个JButton提供相同的actionListener