python连接kafka
发布时间：2019-09-18 07:24:51编辑：auto阅读（3194）
https://blog.csdn.net/see_you_see_me/article/details/78468421
https://zhuanlan.zhihu.com/p/38330574
from kafka import KafkaProducer
producer = KafkaProducer(bootstrap_servers=['10.17.2.11:×××'],value_serializer=lambda v: json.dumps(v).encode('utf-8'), security_protocol="SASL_PLAINTEXT", sasl_mechanism='PLAIN', sasl_plain_username='username', sasl_plain_password='passwd')
producer.send('topic', {'envtype': 'envtype', 'servicename': 'servicename', 'handleinfo': 'handleinfo'})
上一篇： python版wc
下一篇： python curses库
- openvpn linux客户端使用
52231
- H3C基本命令大全
52150
- openvpn windows客户端使用
42298
- H3C IRF原理及 配置
39169
- Python exit()函数
33667
- openvpn mac客户端使用
30621
- python全系列官方中文文档
29319
- python 获取网卡实时流量
24284
- 1.常用turtle功能函数
24172
- python 获取Linux和Windows硬件信息
22542
- LangChain 1.0-Agent中间件-实现闭环(批准-编辑-拒绝动作)
126°
- LangChain 1.0-Agent中间件-汇总消息
127°
- LangChain 1.0-Agent中间件-删除消息
137°
- LangChain 1.0-Agent中间件-消息压缩
128°
- LangChain 1.0-Agent中间件-多模型动态选择
181°
- LangChain1.0-Agent-部署/上线(开发人员必备)
341°
- LangChain1.0-Agent-Spider实战(爬虫函数替代API接口)
386°
- LangChain1.0-Agent(进阶)本地模型+Playwright实现网页自动化操作
386°
- LangChain1.0-Agent记忆管理
362°
- LangChain1.0-Agent接入自定义工具与React循环
402°
- 姓名：Run
- 职业：谜
- 邮箱：383697894@qq.com
- 定位：上海 · 松江
