python连接kafka
发布时间：2019-09-18 07:24:51编辑：auto阅读（3162）
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客户端使用
52059
- H3C基本命令大全
51927
- openvpn windows客户端使用
42154
- H3C IRF原理及 配置
38996
- Python exit()函数
33499
- openvpn mac客户端使用
30450
- python全系列官方中文文档
29084
- python 获取网卡实时流量
24117
- 1.常用turtle功能函数
24023
- python 获取Linux和Windows硬件信息
22373
- LangChain1.0-Agent-部署/上线(开发人员必备)
129°
- LangChain1.0-Agent-Spider实战(爬虫函数替代API接口)
158°
- LangChain1.0-Agent(进阶)本地模型+Playwright实现网页自动化操作
169°
- LangChain1.0-Agent记忆管理
152°
- LangChain1.0-Agent接入自定义工具与React循环
177°
- LangChain1.0-Agent开发流程
163°
- LangChain1.0调用vllm本地部署qwen模型
184°
- LangChain-1.0入门实践-搭建流式响应的多轮问答机器人
194°
- LangChain-1.0入门实战-1
193°
- LangChain-1.0教程-(介绍，模型接入)
207°
- 姓名：Run
- 职业：谜
- 邮箱：383697894@qq.com
- 定位：上海 · 松江
