订阅python使用kafka方法
来源：网络收集 点击： 时间：2024-05-17切换到python3的环境下
2/7pip3 install kafka-python
3/7创建生产者p.py
from kafka import KafkaProducer
producer = KafkaProducer(bootstrap_servers=)
for i in range(1,1001):
str1 = {0}.format(i)
future = producer.send(my_topic , key= bmy_key, value= str.encode(str1), partition= 0)
result = future.get(timeout= 10)
print(result)
4/7vim c.py
from kafka import KafkaConsumer
consumer = KafkaConsumer(my_topic, group_id= group2, bootstrap_servers= )
for msg in consumer:
print(msg)
5/7执行生产者python p.py
6/7消费者进行消费
python p.py
7/7在kafka服务器上查看topic my_topic中的内容，就是1到1000
./kafka-console-consumer.sh --topic my_topic --from-beginning --bootstrap-server kafka-server:9092|more
版权声明：
1、本文系转载，版权归原作者所有，旨在传递信息，不代表看本站的观点和立场。
2、本站仅提供信息发布平台，不承担相关法律责任。
3、若侵犯您的版权或隐私，请联系本站管理员删除。
4、文章链接：http://www.1haoku.cn/art_780579.html
