$ pip install kafka-transport
Package contain init, push, subscribe, fetch async functions:
async init(kafka_host)
async push(topic, value, key)
async subscribe(topic, callback)
async fetch(to, _from, value)
forked from scientistnik/kafka-transport
-
Notifications
You must be signed in to change notification settings - Fork 1
Karma-blockchain/kafka-transport
Folders and files
| Name | Name | Last commit message | Last commit date | |
|---|---|---|---|---|
Repository files navigation
About
python lib for kafka
Resources
Stars
Watchers
Forks
Packages 0
No packages published
Languages
- Python 100.0%