python操作kafka消息生产和消费示例代码
代码语言:python
所属分类:大数据分析
代码描述:python操作kafka消息生产和消费示例代码
代码标签: python 操作 kafka 消息 生产 消费 示例 代码
下面为部分代码预览,完整代码请点击下载或在bfwstudio webide中打开
#!/usr/local/python3/bin/python3 # -*- coding: utf-8 -* from kafka import KafkaProducer, KafkaConsumer from kafka.errors import kafka_errors import traceback import json def producer_demo(): # 假设生产的消息为键值对(不是一定要键值对),且序列化方式为json producer = KafkaProducer( bootstrap_servers=['localhost:9092'], key_serializer=lambda k: json.dumps(k).encode(), value_serializer=lambda v: json.dumps(v).encode()) # 发送三条消息 for i in range(0, 3): future = producer.send( 'kafka_demo', key='count_num', # 同一个key值,会被送至同一个分区 value=str(i), partition=1) # 向分区1发送消息 print("send {}".format(str(i))) try: .........完整代码请登录后点击上方下载按钮下载查看
网友评论0