Add a short description here!
Project description
[](https://travis-ci.org/kryptoflow/kafka-tfrx)
Simple, idiomatic python API to interface Kafka topics with [RxPY](https://github.com/ReactiveX/RxPY)
## Description
The goal of this library is mostly to enable reactive access to Kafka topics. It builds on top of Confluent Kafka’s python [client](https://github.com/confluentinc/confluent-kafka-python), and allows building observable streams from any Kafka topic.
The main motivation for this library is using it with [online learning](https://en.wikipedia.org/wiki/Online_machine_learning), but it is by no means limited to that. In a way, it provides a subset of the functionality that Kafka-Streams offers, which currently does not have a stable python implementation.
## Usage
See examples/
## Tests
Run tox from top level dir
## Note
This project has been set up using PyScaffold 3.0.3. For details and usage information on PyScaffold see <http://pyscaffold.org/>.
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
File details
Details for the file kafka-tfrx-0.14.0.tar.gz.
File metadata
- Download URL: kafka-tfrx-0.14.0.tar.gz
- Upload date:
- Size: 14.5 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: Python-urllib/3.6
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | d7fc8a98fb563fa29877fc28060830294dc8653e0df368e673ee0ed041ab7401 |
|
| MD5 | 1cc4be3922ff1a6e8c62ab4bcd9e0b07 |
|
| BLAKE2b-256 | c45696404ab8ef77aee458715ff13378aaa2d3dd9e1ae2be5cf2288bdb26dadc |
](https://travis-ci.org/kryptoflow/kafka-tfrx){kind=link}