python kafka 使用

安装

pip install kafka-python

生产者

from kafka import KafkaProducer

producer = KafkaProducer(bootstrap_servers='106.112.143.254:59092')
future = producer.send('topic_wx_notice', key=b'my_key', value='my_valuefdsfsdf啊沙发舒服'.encode(), partition=0)
result = future.get(timeout=10)
print(result)

消费者

from kafka import KafkaConsumer

consumer = KafkaConsumer('topic_wx_notice', bootstrap_servers='106.112.143.254:59092',
                         value_deserializer=lambda m: m.decode())
for msg in consumer:
    print(msg)