pykafka生产消费常用api

pykafka基本生产消费常用api
生产者
案例

注意要点: 多进程使用pykafka共享一个client,会造成只有进程能够正常的写入数据,如果使用了dliver_report(包括同步),会导致子进程彻底阻塞掉不可用
消费者
pykafka消费者分为simple和balanced两种
simple适用于需要消费指定分区且不需要自动的重分配(自定义)
balanced自动分配则选择
案例

HTTPX 基础教程-新乡seo|网站优化,网站建设_微信公众号:zeropython—昊天博客