使用Python连接rocketmq获取topic里的消息

时间：2020-06-06 18:20:40 收藏：0 阅读：770

rocketmq第三方库只支持mac和Linux，需注意！！

#*encoding=utf-8

from rocketmq.client import PullConsumer

consumer = PullConsumer(‘CID_XXX‘)

consumer.set_namesrv_addr(‘192.168.0.1:9876‘)

consumer.start()

while True:
    for msg in consumer.pull(‘msg-topic‘):print(msg.id, msg.body)


consumer.shutdown()

原文：https://www.cnblogs.com/siyz/p/13055584.html