kafka-bridge-client 0.1.3

Python client for Strimzi Kafka Bridge

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()