This is the test-bed adapter for Python: it allows you to easily connect Python services to the Apache Kafka test-bed via Python.
This is the test-bed adapter for Python: it allows you to easily connect Python services to the Apache Kafka test-bed via Python. Although it is specifically created for connecting to our test-bed, it should work for any Apache Kafka version too.
- AVRO schema's and messages: both key's and values should have a schema as explained here.
- Kafka consumer and producer for the test-bed topics.
- Heartbeat (topic: connect-status-heartbeat), so you know which clients are online. Each time the test-bed-adapter is executed, it starts a heartbeat process to notify the its activity to other clients.
- Configuration (topic: connect-status-configuration), so you can see which topics clients consume and produce.
You need to install Python 3+.
To install the PYPI package run
pip3 install python-test-bed-adapter
Using the Github repo
If you clone the Github repository, to run the examples you will need to install the dependencies
specified on the file
For that, run
pip3 install -r requirements.txt
from the project folder.
Examples and usage
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
|Filename, size||File type||Python version||Upload date||Hashes|
|Filename, size python_test_bed_adapter-0.0.6-py3-none-any.whl (21.3 kB)||File type Wheel||Python version py3||Upload date||Hashes View hashes|
|Filename, size python-test-bed-adapter-0.0.6.tar.gz (11.7 kB)||File type Source||Python version None||Upload date||Hashes View hashes|
Hashes for python_test_bed_adapter-0.0.6-py3-none-any.whl
Hashes for python-test-bed-adapter-0.0.6.tar.gz