kafka-bridge-client
Python async client for Strimzi Kafka Bridge and Confluent REST Proxy Package include consumer only.
Install
pip install kafka-bridge-client
Usage
By default client use Strimzi Kafka Bridge API
Consumer (async)
from kafka_bridge_client import KafkaBridgeConsumer
# Strimzi Kafka Bridge
consumer1 = 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',
)
# Confluent REST Proxy
consumer2 = 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',
proxy='confluent'
)
async for rec in consumer1.get_records():
print(rec['value'])
await consumer.commit()
# or
records = await consumer1.poll_records()
print(records)
await consumer.commit()
Producer (sync)
from kafka_bridge_client import KafkaBridgeProducer
producer = KafkaBridgeProducer('http://bridge.url' timeout=5)
producer.send(Message(key='1', value='value'))
Deploy
You need to change version in pyproject.toml and run it
poetry publish --build
2 maintainers
Metadata
2 maintainers
Release files for kafka-bridge-client 0.7.1
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| kafka_bridge_client-0.7.1.tar.gz | 5.5 kB | Details |
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| kafka_bridge_client-0.7.1-py3-none-any.whl | Python 3 | none | any | Details |
Total release size: 12.5 kB
Release files / kafka_bridge_client-0.7.1.tar.gz
| Download URL | kafka_bridge_client-0.7.1.tar.gz |
|---|---|
| Size | 5.5 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
60a1bb4c0c35aef4d49c25309ecc604a382bf6d2bd80617dc3eb70abfa0232ab
|
|
BLAKE2b-256 checksum How to use checksums |
f13c1690b118bd188aca4c941f0f21397daa80352c0ae9522ee13d6cc247b92c
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
poetry/1.5.1 CPython/3.8.16 Darwin/22.5.0
|
Release files / kafka_bridge_client-0.7.1-py3-none-any.whl
| Download URL | kafka_bridge_client-0.7.1-py3-none-any.whl |
|---|---|
| Size | 7.0 kB |
| Tags | Python 3 |
|
SHA-256 checksum How to use checksums |
f6abf3c21536c520887b0571400be3cb8e491d891973158f27549fa2c6217e99
|
|
BLAKE2b-256 checksum How to use checksums |
975b51e6d7baea1ae46820a8767a39254f1f0e00a9c2a8aaba02a6629137b557
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
poetry/1.5.1 CPython/3.8.16 Darwin/22.5.0
|
