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.1.tar.gz
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | e1801b50a35d143f17e0412a89c4c7c839313eb3cf016c168d94572fa488e2a5 |
|
| MD5 | b628eacdf426ab11c72dd232ba5c2bfc |
|
| BLAKE2b-256 | d1fad9021d6746caeb3693e6eeb3d6a096ee2a10254f13a95b12932ebc067ede |
Close
Hashes for kafka_bridge_client-0.1.1-py3-none-any.whl
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | cc8acfc958925043aef32a8446a4479867b0b3caee51f76f38005f13db4c484c |
|
| MD5 | ad4d02fff660d2710575de311c439b37 |
|
| BLAKE2b-256 | c7f2dd860d37db9b3a44dcbc9c03ed075066ee25a8f71f0c3790ef94c6d6f683 |
