an easy to use kafka consumer that extends kafka-python, but follows the style of the flask server
Project description
# kafkaesque
This A flask style kafka consumer. It is an extention of the KafkaConsumer from the kafka-python package available [`here`](https://github.com/dpkp/kafka-python)
## Installation
```sh
pip install kafkaesque
```
## writing a consumer looks like this
```
from kafkaesque import Kafkaesque
app = Kafkaesque(
bootstrap_servers=",".join([
"bs_1:9092",
"bs_2:9093",
"bs_3:9094"
]),
group_id="consumer-grp-id"
)
@app.handle('test-topic')
def test_topic_handler(msg):
print "consumed {} from test-topic".format(msg)
if __name__ == "__main__":
app.start()
```
## Author
* **Sankalp Jonna**
Email me with any queries: [sankalpjonna@gmail.com](sankalpjonna@gmail.com).
This A flask style kafka consumer. It is an extention of the KafkaConsumer from the kafka-python package available [`here`](https://github.com/dpkp/kafka-python)
## Installation
```sh
pip install kafkaesque
```
## writing a consumer looks like this
```
from kafkaesque import Kafkaesque
app = Kafkaesque(
bootstrap_servers=",".join([
"bs_1:9092",
"bs_2:9093",
"bs_3:9094"
]),
group_id="consumer-grp-id"
)
@app.handle('test-topic')
def test_topic_handler(msg):
print "consumed {} from test-topic".format(msg)
if __name__ == "__main__":
app.start()
```
## Author
* **Sankalp Jonna**
Email me with any queries: [sankalpjonna@gmail.com](sankalpjonna@gmail.com).
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
kafkaesque-1.0.tar.gz
(2.2 kB
view hashes)
Built Distributions
kafkaesque-1.0-py2.7.egg
(4.2 kB
view hashes)