Skip to main content
Join the official 2019 Python Developers SurveyStart the survey!

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.

Files for python-test-bed-adapter, version 0.0.6
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

Supported by

Elastic Elastic Search Pingdom Pingdom Monitoring Google Google BigQuery Sentry Sentry Error logging AWS AWS Cloud computing DataDog DataDog Monitoring Fastly Fastly CDN SignalFx SignalFx Supporter DigiCert DigiCert EV certificate StatusPage StatusPage Status page