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 | RSS feed

This version

1.0

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)

Uploaded Source

Built Distributions

kafkaesque-1.0-py2.7.egg (4.2 kB view details)

Uploaded Source

kafkaesque-1.0-py2-none-any.whl (3.8 kB view details)

Uploaded Python 2

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

Hashes for kafkaesque-1.0.tar.gz
Algorithm Hash digest
SHA256 8ceeebdf31dfb11019e6d80d263be0ad2a1bdffc3b88fd94382e2a7896764936
MD5 17a0697937b665e745a6e9afa26f0631
BLAKE2b-256 3c11b4172a8f24574d571169da1f9e7b73a421a921f097976d84ac1f2bf027a1

See more details on using hashes here.

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

Hashes for kafkaesque-1.0-py2.7.egg
Algorithm Hash digest
SHA256 ca732dc17d4e07061fd07cb34c82c9527d0de5afa8ea678507be140e48518b1f
MD5 de896d38d3057662bf00ac1b0cc81143
BLAKE2b-256 be76a3b89d942748e1a4f8b3f25813a046812db31ab9efeb635673c7d44e3ad4

See more details on using hashes here.

File details

Details for the file kafkaesque-1.0-py2-none-any.whl.

File metadata

File hashes

Hashes for kafkaesque-1.0-py2-none-any.whl
Algorithm Hash digest
SHA256 4fe3cf066ad31ea0640eb7c889a15b10a325c3cf1f8e44cd5e13a90e71e1f76b
MD5 473920cffdd66963e985fed4453cd2b0
BLAKE2b-256 5e14200712cd6eff8b01c97f1da5acc5c8fb4bd996deea4e2420ded5fdb5b99f

See more details on using hashes here.

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page