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(
'topic1',
'topic2',
group_id='my-group,
auto_offset_reset='earliest',
enable_auto_commit=False,
bootstrap_server='your-kafka-bridge-url',
consumer_name='consumer-name',
)
async for rec in consumer.get_records():
print(rec['value'])
await consumer.commit()
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
File details
Details for the file kafka-bridge-client-0.1.3.tar.gz.
File metadata
- Download URL: kafka-bridge-client-0.1.3.tar.gz
- Upload date:
- Size: 4.2 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: poetry/1.1.8 CPython/3.9.6 Linux/5.13.13-1-MANJARO
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | c89822bd14508b99c81ef160e6336a676dc290bdddf1158a956f422b5ca51bad |
|
| MD5 | e19a48f79cc08951c5dacc48a3dd22fb |
|
| BLAKE2b-256 | 81137ad57cde748a52623be20047e42611ca66eff05ac541e48482386a07d540 |
File details
Details for the file kafka_bridge_client-0.1.3-py3-none-any.whl.
File metadata
- Download URL: kafka_bridge_client-0.1.3-py3-none-any.whl
- Upload date:
- Size: 4.9 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via: poetry/1.1.8 CPython/3.9.6 Linux/5.13.13-1-MANJARO
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | 6e1741c8a07182ca3b660d6929004a7d23b4391f71068df460267ea7f3e6d98b |
|
| MD5 | 24fdc75625541fc2cdd00979000471f2 |
|
| BLAKE2b-256 | 6513f299662d39f7b62d22c2eb93c1238fa355fbe6a4369cf415055d95e26482 |
