python连接kafka
发布时间：2019-09-18 07:24:51编辑：auto阅读（3211）
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客户端使用
52301
- H3C基本命令大全
52210
- openvpn windows客户端使用
42356
- H3C IRF原理及 配置
39242
- Python exit()函数
33722
- openvpn mac客户端使用
30677
- python全系列官方中文文档
29400
- python 获取网卡实时流量
24343
- 1.常用turtle功能函数
24223
- python 获取Linux和Windows硬件信息
22589
- LangChain接入自定义爬虫-MCP工具
40°
- LangChain接入Filesystem-MCP工具
40°
- LangChain搭建MCP服务端和客户端流程
83°
- LangGraph与MCP技术概述
80°
- LangChain 1.0-Agent中间件-实现闭环(批准-编辑-拒绝动作)
202°
- LangChain 1.0-Agent中间件-汇总消息
190°
- LangChain 1.0-Agent中间件-删除消息
201°
- LangChain 1.0-Agent中间件-消息压缩
207°
- LangChain 1.0-Agent中间件-多模型动态选择
244°
- LangChain1.0-Agent-部署/上线(开发人员必备)
427°
- 姓名：Run
- 职业：谜
- 邮箱：383697894@qq.com
- 定位：上海 · 松江
