Strimzi Kafka Bridge的Python客户端
项目描述
kafka-bridge-client
Python异步客户端，用于Strimzi Kafka Bridge和Confluent REST代理。包仅包含消费者。
安装
pip install kafka-bridge-client
用法
默认情况下，客户端使用Strimzi Kafka Bridge API
消费者（异步）
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()
生产者（同步）
from kafka_bridge_client import KafkaBridgeProducer
producer = KafkaBridgeProducer('http://bridge.url' timeout=5)
producer.send(Message(key='1', value='value'))
部署
您需要更改pyproject.toml中的版本并运行它
poetry publish --build
下载文件
下载适合您平台的自定义文件。如果您不确定选择哪个，请了解有关安装包的更多信息。
源代码分发
kafka_bridge_client-0.7.1.tar.gz (5.5 kB 查看哈希值)
构建分发
关闭
kafka_bridge_client-0.7.1.tar.gz 的哈希值
| 算法 | 哈希摘要 | |
|---|---|---|
| SHA256 | 60a1bb4c0c35aef4d49c25309ecc604a382bf6d2bd80617dc3eb70abfa0232ab |
|
| MD5 | 5860841399fb131b46214e1281ea35da |
|
| BLAKE2b-256 | f13c1690b118bd188aca4c941f0f21397daa80352c0ae9522ee13d6cc247b92c |
关闭
kafka_bridge_client-0.7.1-py3-none-any.whl 的哈希值
| 算法 | 哈希摘要 | |
|---|---|---|
| SHA256 | f6abf3c21536c520887b0571400be3cb8e491d891973158f27549fa2c6217e99 |
|
| MD5 | 6edd9e98e0eb9ed4e8ecd056fe55318e |
|
| BLAKE2b-256 | 975b51e6d7baea1ae46820a8767a39254f1f0e00a9c2a8aaba02a6629137b557 |