Skip to main content

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.

Installation

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 requirements.txt For that, run pip3 install -r requirements.txt from the project folder.

Examples and usage

Check the examples of consumer and producer.

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

python-test-bed-adapter-0.0.6.tar.gz (11.7 kB view details)

Uploaded Source

Built Distribution

python_test_bed_adapter-0.0.6-py3-none-any.whl (21.3 kB view details)

Uploaded Python 3

File details

Details for the file python-test-bed-adapter-0.0.6.tar.gz.

File metadata

  • Download URL: python-test-bed-adapter-0.0.6.tar.gz
  • Upload date:
  • Size: 11.7 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/1.12.1 pkginfo/1.5.0.1 requests/2.21.0 setuptools/40.6.3 requests-toolbelt/0.8.0 tqdm/4.29.1 CPython/3.6.6

File hashes

Hashes for python-test-bed-adapter-0.0.6.tar.gz
Algorithm Hash digest
SHA256 65d5152768f5bd9189fab12b0bba82d05557e3fc0112e6d61a731e9c473434ae
MD5 a4af7bd46b773965b7df1cf45c59e259
BLAKE2b-256 92cfe901053211f489d807f280fb82daa61ddcec0110a1804924be01ff7908cb

See more details on using hashes here.

File details

Details for the file python_test_bed_adapter-0.0.6-py3-none-any.whl.

File metadata

  • Download URL: python_test_bed_adapter-0.0.6-py3-none-any.whl
  • Upload date:
  • Size: 21.3 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/1.12.1 pkginfo/1.5.0.1 requests/2.21.0 setuptools/40.6.3 requests-toolbelt/0.8.0 tqdm/4.29.1 CPython/3.6.6

File hashes

Hashes for python_test_bed_adapter-0.0.6-py3-none-any.whl
Algorithm Hash digest
SHA256 62d2ef3b3a09e085ed43440e7ea155e05325d96ade3bef364e8fe538f4309864
MD5 977169218c153d4ddab2133da2d2162a
BLAKE2b-256 e7dec1d0544eb6348d1913a218feb4fb2ef0172607fb35269b4aa7be81b0bdca

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page