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
=.........完整代码请登录后点击上方下载按钮下载查看

网友评论0