python连接kafka
发布时间：2019-09-18 07:24:51编辑：auto阅读（3494）
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库
- H3C基本命令大全
53789
- H3C IRF原理及 配置
40612
- Python exit()函数
35063
- python全系列官方中文文档
30774
- python 获取网卡实时流量
25644
- 1.常用turtle功能函数
25407
- python 获取Linux和Windows硬件信息
23840
- 天天基金网数据接口
19329
- Selenium使用代理IP&无头模式访问网站
15433
- Selenium&Pytesseract模拟登录+验证码识别
14938
- LangGraph Studio可视化
1535°
- LangSmith开发-应用入门
1413°
- LangGraph开发-多轮对话问答机器人
1512°
- LangGraph开发-条件分支/循环图实战
1550°
- LangGraph开发-生态介绍，入门demo实战
1560°
- LangChain-接入12306-HTTP MCP智能体
1750°
- LangChain接入自定义爬虫-MCP工具
1705°
- LangChain接入Filesystem-MCP工具
1563°
- LangChain搭建MCP服务端和客户端流程
1666°
- LangGraph与MCP技术概述
1611°
- 姓名：Run
- 职业：谜
- 邮箱：383697894@qq.com
- 定位：上海 · 松江
