Skip to main content

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).

Project details


Release history Release notifications

This version
History Node

1.0

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Filename, size & hash SHA256 hash help File type Python version Upload date
kafkaesque-1.0-py2.7.egg (4.2 kB) Copy SHA256 hash SHA256 Egg 2.7 Jul 13, 2018
kafkaesque-1.0-py2-none-any.whl (3.8 kB) Copy SHA256 hash SHA256 Wheel py2 Jul 13, 2018
kafkaesque-1.0.tar.gz (2.2 kB) Copy SHA256 hash SHA256 Source None Jul 13, 2018

Supported by

Elastic Elastic Search Pingdom Pingdom Monitoring Google Google BigQuery Sentry Sentry Error logging AWS AWS Cloud computing DataDog DataDog Monitoring Fastly Fastly CDN DigiCert DigiCert EV certificate StatusPage StatusPage Status page