To install manually, first download and unzip the kiel-0.9.4-dev.tar.gz, then:
tar -zxvf kiel-0.9.4-dev.tar.gz cd kiel-0.9.4-dev python setup.py install
Example scripts can be found in the examples directory in the repo.
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.