Python kafka生产者消费者

生产者

# coding=utf-8
# 生产者脚本
import json

from kafka import KafkaProducer

producer = KafkaProducer(bootstrap_servers="10.44.99.103:9092")
msg_dict = {
            'method':"post",
            'header':'json',
            'content':"19092",
 }
print(msg_dict)

msg = json.dumps(msg_dict).encode(encoding='utf-8')
producer.send('td-test',msg)
producer.close()

消费者

# coding=utf-8
# 消费者脚本
from kafka import KafkaConsumer

consumer = KafkaConsumer('td-test', bootstrap_servers=['10.44.99.103:9092'])
for msg in consumer:
    recv = "%s:%d:%d: key=%s value=%s" % (msg.topic, msg.partition, msg.offset, msg.key, msg.value)
    print (recv)

注：

1）在 windows 和 linux 上 是有一些区别的，首先在 windows 上要进行编码  encode ，而在 linux 上是不需要进行编码的。

2）在 windows 的 C:WindowsSystem32driversetchosts 文件要添加 IP地址 与 节点名