This is the test-bed adapter for Python: it allows you to easily connect Python services to the Apache Kafka test-bed via Python.
Project description
python-test-bed-adapter
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.
The implementation is a wrapper around Pykafka and avro-python3 offering support for:
- 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.
- Management
- 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.
Pre-requisites
You need to install Python 3+.
After that to install the dependencies specified on the file
requirements.txt
run
pip3 install -r requirements.txt
Examples and usage
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Close
Hashes for python-test-bed-adapter-0.0.1.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 5fc7aebb6ca3d85da4350c2b16816126a9f7cccb5d57f32d1936a9f0655dc6f9 |
|
MD5 | 7fd8f65bf0dc94029c26f23fc9e3893c |
|
BLAKE2b-256 | 8443f445bf237a896879aefba51dec9e0705ec9ed0625d59ef1421911df34e35 |
Close
Hashes for python_test_bed_adapter-0.0.1-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 501a0c357b03e5958ee0efe4540b352e7bb12ec6709f32e22b056d3a3fb46a4d |
|
MD5 | 9ac46cf8d32e6b963d753cc53a9a519a |
|
BLAKE2b-256 | 5a350aab1cb4d0e7b39b9521db1168dc6ed9b56a03907dde2e0e27713c0dea2e |