测开之路七十四:python处理kafka
2024-10-03 10:27:59
kafka-python地址:https://github.com/dpkp/kafka-python
安装kafka-python:pip install kafka-python
接收消息
from kafka import KafkaConsumer
consumer = KafkaConsumer('test', bootstrap_servers=['localhost:9092']) # 定义消费者
for msg in consumer:
print(msg)
发条消息尝试接收,结果是byte类型
发送消息
from kafka import KafkaProducer
import json data = '123qweasd45'
producer = KafkaProducer(bootstrap_servers=['localhost:9092'],
value_serializer=lambda v: json.dumps(v).encode('utf-8'))
# value_serializer=lambda v: json.dumps(v).encode('utf-8'):由于默认发送的数据是byte,这里把要发送的数据序列化成json
producer.send('test', json.dumps(data), partition=0)
producer.close()
执行投递消息,查看消费者的输出
窗口也可以展示
最新文章
- JavaScript 变量
- C# 访问MongoDB 通用方法类
- 【mysql】关于乐观锁
- 【转载】区间信息的维护与查询(一)——二叉索引树(Fenwick树、树状数组)
- Rhythmbox中文乱码
- Linux_文档编辑器_简介
- vim快捷键笔记【原创】
- 李洪强iOS开发之宏定义方法来初始化一个单例对象
- unity3D中协程和线程混合
- jQuery EasyUI之DataGrid使用示例
- tp中phpexcel导出实例
- jQuery查询性能考虑
- ArcGIS中实现指定面积蜂窝(正六边形)方法
- Hystrix-request collapsing(请求合并)
- MySQL Group Relication 部署环境入门篇
- pygame事件之——控制物体(飞机)的移动
- js 个人笔记
- 在SQL Server中如何进行UPDATE TOP .....ORDER BY?
- python——获取文件列表
- 警惕32位程序在MethodImplOptions.Synchronized在x64机器上的同步缺陷[z]
热门文章
- 从ES6重新认识JavaScript设计模式: 装饰器模式
- 移动端300ms延迟原理,穿透、遮罩层滑动导致下面滑动总结
- 使用JSONP,jQuery的ajax跨域获取json数据
- 通过离线安装包解决了 from cryptography.hazmat.bindings._openssl import ffi, lib ImportError: /usr/local/python36/lib/python3.6/site-packages/cryptography-2.2.2-py3.6-linux-x86_64.egg/cryptography/hazmat/binding
- 09.Linux系统由于不正常关机导致的分区问题
- python基础--局部变量与全局变量
- less: 变量
- Ubuntu环境下SSH服务安装、SSH远程登录以及SSH数据传输
- 06.队列、python标准库中的双端队列、迷宫问题
- NODE升级到V12.X.X