franz:Lite Kafkarabbitmq包装器

弗朗兹 围绕和精简包装。 用法 安装 pip install franz （推荐） pip -e [email protected]:eshares/franz.git@master#egg=franz 将@master更改为版本或根据需要提交。 兔子MQ 传送讯息 import random import time import franz class FranzData ( franz . FranzEvent ): def serialize ( self ): return { 'data' : time . time ()} with franz . RabbitProducer ( exchange = 'topic_link' ) as p : while True : key = random . choice ([ 'h