kafka Py客户端

Posted lwhctv

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了kafka Py客户端相关的知识，希望对你有一定的参考价值。

1.pip install kafka-python
2.Producer.py
from kafka import KafkaProducer
producer = KafkaProducer(bootstrap_servers=‘10.32.106.42:9092‘)
for _ in range(1000):
    producer.send(‘foobar‘, b‘some_message_bytes‘)
3.consumer.py
from kafka import KafkaConsumer
consumer = KafkaConsumer(‘TestTopic‘,bootstrap_servers=[‘10.32.106.42:9092‘])
for msg in consumer:
    print("%s:%d:%d: key=%s value=%s" % (msg.topic, msg.partition, msg.offset, msg.key, msg.value))

 

以上是关于kafka Py客户端的主要内容，如果未能解决你的问题，请参考以下文章