kafka-helper

Makes it easy to use the kafka-python library with Apache Kafka on Heroku


Keywords
kafka, heroku, kafka-python
License
MIT
Install
pip install kafka-helper==0.2

Documentation

kafka_helper

kafka_helper makes it easy to use the kafka-python library with Apache Kafka on Heroku. It takes care of parsing the Kafka config vars and establishing an SSL context.

NOTE: The kafka_helper library is not officially supported by Heroku.

Installation

pip install kafka-helper

Usage

import kafka_helper

To get a producer and write some values to a topic:

producer = kafka_helper.get_kafka_producer()
producer.send('my-topic', key='my key', value={'k': 'v'})

To get a consumer of a topic and iterate over its stream:

consumer = kafka_helper.get_kafka_consumer(topic='my-topic')
for message in consumer:
    print(message)