没有合适的资源?快使用搜索试试~ 我知道了~
首页kafka-python开发文档
资源详情
资源评论
资源推荐
kafka-python Documentation
Release 1.3.3.dev
Dana Powers
February 03, 2017
Contents
1 KafkaConsumer 3
2 KafkaProducer 5
3 Compression 7
4 Protocol 9
5 Low-level 11
5.1 Usage . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 11
5.2 kafka-python API . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 13
5.3 Simple APIs (DEPRECATED) . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 29
5.4 Install . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 32
5.5 Tests . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 33
5.6 Compatibility . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 34
5.7 Support . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 34
5.8 License . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 34
5.9 Changelog . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 34
i
ii
kafka-python Documentation, Release 1.3.3.dev
Python client for the Apache Kafka distributed stream processing system. kafka-python is designed to function much
like the official java client, with a sprinkling of pythonic interfaces (e.g., consumer iterators).
kafka-python is best used with newer brokers (0.10 or 0.9), but is backwards-compatible with older versions (to
0.8.0). Some features will only be enabled on newer brokers, however; for example, fully coordinated consumer
groups – i.e., dynamic partition assignment to multiple consumers in the same group – requires use of 0.9 kafka
brokers. Supporting this feature for earlier broker releases would require writing and maintaining custom leadership
election and membership / health check code (perhaps using zookeeper or consul). For older brokers, you can achieve
something similar by manually assigning different partitions to each consumer instance with config management
tools like chef, ansible, etc. This approach will work fine, though it does not support rebalancing on failures. See
Compatibility for more details.
Please note that the master branch may contain unreleased features. For release documentation, please see readthedocs
and/or python’s inline help.
>>> pip install kafka-python
Contents 1
剩余55页未读,继续阅读
ecjtuQX
- 粉丝: 0
- 资源: 1
上传资源 快速赚钱
- 我的内容管理 收起
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
会员权益专享
最新资源
- 27页智慧街道信息化建设综合解决方案.pptx
- 计算机二级Ms-Office选择题汇总.doc
- 单链表的插入和删除实验报告 (2).docx
- 单链表的插入和删除实验报告.pdf
- 物联网智能终端项目设备管理方案.pdf
- 如何打造品牌的模式.doc
- 样式控制与页面布局.pdf
- 武汉理工Java实验报告(二).docx
- 2021线上新品消费趋势报告.pdf
- 第3章 Matlab中的矩阵及其运算.docx
- 基于Web的人力资源管理系统的必要性和可行性.doc
- 基于一阶倒立摆的matlab仿真实验.doc
- 速运公司物流管理模式研究教材
- 大数据与管理.pptx
- 单片机课程设计之步进电机.doc
- 大数据与数据挖掘.pptx
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功
评论0