# 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).
Metadata
Release files for kafkaesque 1.0
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| kafkaesque-1.0.tar.gz | 2.2 kB | Details |
Built distributions (wheels)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| kafkaesque-1.0-py2.7.egg | Legacy Egg format | - | - | Details |
| kafkaesque-1.0-py2-none-any.whl | Python 2 | none | any | Details |
Total release size: 10.2 kB
Release files / kafkaesque-1.0.tar.gz
| Download URL | kafkaesque-1.0.tar.gz |
|---|---|
| Size | 2.2 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
8ceeebdf31dfb11019e6d80d263be0ad2a1bdffc3b88fd94382e2a7896764936
|
|
BLAKE2b-256 checksum How to use checksums |
3c11b4172a8f24574d571169da1f9e7b73a421a921f097976d84ac1f2bf027a1
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
Release files / kafkaesque-1.0-py2.7.egg
| Download URL | kafkaesque-1.0-py2.7.egg |
|---|---|
| Size | 4.2 kB |
| Tags | Egg |
|
SHA-256 checksum How to use checksums |
ca732dc17d4e07061fd07cb34c82c9527d0de5afa8ea678507be140e48518b1f
|
|
BLAKE2b-256 checksum How to use checksums |
be76a3b89d942748e1a4f8b3f25813a046812db31ab9efeb635673c7d44e3ad4
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
Release files / kafkaesque-1.0-py2-none-any.whl
| Download URL | kafkaesque-1.0-py2-none-any.whl |
|---|---|
| Size | 3.8 kB |
| Tags | Python 2 |
|
SHA-256 checksum How to use checksums |
4fe3cf066ad31ea0640eb7c889a15b10a325c3cf1f8e44cd5e13a90e71e1f76b
|
|
BLAKE2b-256 checksum How to use checksums |
5e14200712cd6eff8b01c97f1da5acc5c8fb4bd996deea4e2420ded5fdb5b99f
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |