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 details)
Built Distributions
kafkaesque-1.0-py2.7.egg
(4.2 kB
view details)
File details
Details for the file kafkaesque-1.0.tar.gz
.
File metadata
- Download URL: kafkaesque-1.0.tar.gz
- Upload date:
- Size: 2.2 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | 8ceeebdf31dfb11019e6d80d263be0ad2a1bdffc3b88fd94382e2a7896764936 |
|
MD5 | 17a0697937b665e745a6e9afa26f0631 |
|
BLAKE2b-256 | 3c11b4172a8f24574d571169da1f9e7b73a421a921f097976d84ac1f2bf027a1 |
File details
Details for the file kafkaesque-1.0-py2.7.egg
.
File metadata
- Download URL: kafkaesque-1.0-py2.7.egg
- Upload date:
- Size: 4.2 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | ca732dc17d4e07061fd07cb34c82c9527d0de5afa8ea678507be140e48518b1f |
|
MD5 | de896d38d3057662bf00ac1b0cc81143 |
|
BLAKE2b-256 | be76a3b89d942748e1a4f8b3f25813a046812db31ab9efeb635673c7d44e3ad4 |
File details
Details for the file kafkaesque-1.0-py2-none-any.whl
.
File metadata
- Download URL: kafkaesque-1.0-py2-none-any.whl
- Upload date:
- Size: 3.8 kB
- Tags: Python 2
- Uploaded using Trusted Publishing? No
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | 4fe3cf066ad31ea0640eb7c889a15b10a325c3cf1f8e44cd5e13a90e71e1f76b |
|
MD5 | 473920cffdd66963e985fed4453cd2b0 |
|
BLAKE2b-256 | 5e14200712cd6eff8b01c97f1da5acc5c8fb4bd996deea4e2420ded5fdb5b99f |