Provides a Kafka implementation of the ChannelInput/OutputPort in pypz.
Project description
Local testing
To test it locally, start confluent's pre-made image:
docker run -it --rm -p 9092:9092 confluentinc/confluent-local
For more information refer to: https://hub.docker.com/r/confluentinc/confluent-local
0
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
pypz-kafka-io-0.9.0b5.tar.gz
(7.5 kB
view hashes)
Built Distribution
Close
Hashes for pypz_kafka_io-0.9.0b5-py3-none-any.whl
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | a8767217f835dcb780674aee8795b1bef3a3f83d00df0d6892c9d5fe44acb135 |
|
| MD5 | 47037d99fd6e3fc85780a718cc920323 |
|
| BLAKE2b-256 | 6579251158efc2f8b946276868e663c465745a9c55c46be8fbb4834409a34132 |
