Skip to main content

Python client for Strimzi Kafka Bridge

Project description

kafka-bridge-client

Python async client for Strimzi Kafka Bridge and Confluent REST Proxy Package include consumer only.

License: MIT PRs Welcome PyPI version

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

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

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

kafka-bridge-client-0.5.1.tar.gz (5.8 kB view details)

Uploaded Source

Built Distribution

kafka_bridge_client-0.5.1-py3-none-any.whl (6.9 kB view details)

Uploaded Python 3

File details

Details for the file kafka-bridge-client-0.5.1.tar.gz.

File metadata

  • Download URL: kafka-bridge-client-0.5.1.tar.gz
  • Upload date:
  • Size: 5.8 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: poetry/1.1.13 CPython/3.10.2 Linux/5.15.28-1-MANJARO

File hashes

Hashes for kafka-bridge-client-0.5.1.tar.gz
Algorithm Hash digest
SHA256 6ad17c76c2e96446735e811a95c07e29cc0f924be6700955b97faf5795f87016
MD5 fa0f28a509dc278a7c14ce1259f3f547
BLAKE2b-256 a70a3fb6d78b5abae700c7d5ef924ce4a98ba838925d83339666084586370f49

See more details on using hashes here.

File details

Details for the file kafka_bridge_client-0.5.1-py3-none-any.whl.

File metadata

File hashes

Hashes for kafka_bridge_client-0.5.1-py3-none-any.whl
Algorithm Hash digest
SHA256 8494a98bde9e456544e4acba4a12f4629211f85d26d223fe2d3576360c190a0b
MD5 a99f07a19c4541a15b94c1e23c257066
BLAKE2b-256 0e76238c9e10deb2e7a30d85e8bfed0e40b5e9d703facf398e4a0b3c402db18f

See more details on using hashes here.

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page