Kafka Center for Tornado Async Applications.
kiel的Python项目详细描述
kiel是一个纯pythonKafka客户端库,用于Tornado 应用。
安装
手动
若要手动安装,请首先克隆此here repo并:
cd kiel python setup.py install
文件
可以在Read The Docs上找到更详细的信息。
快速消费示例
fromkielimportclientsfromtornadoimportgen,ioloop@gen.coroutinedefconsume():c=clients.SingleConsumer(brokers=["localhost"])yieldc.connect()whileTrue:msgs=yieldc.consume("examples.colors")formsginmsgs:print(msg["color"])defrun():loop=ioloop.IOloop.instance()loop.add_callback(consume)try:loop.start()exceptKeyboardInterrupt:loop.stop()