Kiel is a pure python Kafka client library for use with Tornado applications.

Kiel is available via PyPI, installation is as easy as:

pip install kiel

To install manually, first clone this here repo and:

cd kiel
python setup.py install

More detailed information can be found on Read The Docs.

from kiel import clients
from tornado import gen, ioloop


@gen.coroutine
def consume():
    c = clients.SingleConsumer(brokers=["localhost"])

    yield c.connect()

    while True:
        msgs = yield c.consume("examples.colors")
        for msg in msgs:
            print(msg["color"])


def run():
    loop = ioloop.IOloop.instance()

    loop.add_callback(consume)

    try:
        loop.start()
    except KeyboardInterrupt:
        loop.stop()

The code is hosted on GitHub

To file a bug or possible enhancement see the Issue Tracker, also found on GitHub.

(c) 2015-2016 William Glass

Kiel is licensed under the terms of the Apache License (2.0). See the LICENSE file for more details.