Python client for Strimzi Kafka Bridge
Project description
kafka-bridge-client
Python async client for Strimzi Kafka Bridge. Package include consumer only.
Install
pip install kafka-bridge-client
Usage
from kafka_bridge_client import KafkaBridgeConsumer
consumer = KafkaBridgeConsumer(
CONFIG['topics']['name'],
group_id=CONFIG['group_id'],
auto_offset_reset='earliest',
enable_auto_commit=False,
bootstrap_server=CONFIG['kafka_bridge']['url'],
consumer_name='consumer-name',
)
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
Built Distribution
Close
Hashes for kafka-bridge-client-0.1.2.tar.gz
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | 1e9c8aaec8255c2e96b2a0fd9db4c9cb28dba3f00f17068078af023455661100 |
|
| MD5 | cd8b9d0f320971e9b2732afede817bd4 |
|
| BLAKE2b-256 | 2806041c2995db95229f9fc028cba866b22f43e402fad4cfc2da0228537184cc |
Close
Hashes for kafka_bridge_client-0.1.2-py3-none-any.whl
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | 94233752130b019bbd48daa2f304c10db8ac4cd6d3baf1fa55dc096ec9e2611f |
|
| MD5 | 08463b3e4b0a22633ddbf251c6118f2c |
|
| BLAKE2b-256 | df6c8f965c19834639a47db17e11ca8c106b4e74fca8719bb93f0a38a2bccd24 |
