Skip to main content

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(
    CONFIG['topics']['name'],
    group_id=CONFIG['group_id'],
    auto_offset_reset='earliest',
    enable_auto_commit=False,
    bootstrap_server=CONFIG['kafka_bridge']['url'],
    consumer_name='consumer-name',
)

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.1.1.tar.gz (4.0 kB view details)

Uploaded Source

Built Distribution

kafka_bridge_client-0.1.1-py3-none-any.whl (4.7 kB view details)

Uploaded Python 3

File details

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

File metadata

  • Download URL: kafka-bridge-client-0.1.1.tar.gz
  • Upload date:
  • Size: 4.0 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: poetry/1.1.6 CPython/3.9.5 Linux/5.12.11-300.fc34.x86_64

File hashes

Hashes for kafka-bridge-client-0.1.1.tar.gz
Algorithm Hash digest
SHA256 e1801b50a35d143f17e0412a89c4c7c839313eb3cf016c168d94572fa488e2a5
MD5 b628eacdf426ab11c72dd232ba5c2bfc
BLAKE2b-256 d1fad9021d6746caeb3693e6eeb3d6a096ee2a10254f13a95b12932ebc067ede

See more details on using hashes here.

File details

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

File metadata

  • Download URL: kafka_bridge_client-0.1.1-py3-none-any.whl
  • Upload date:
  • Size: 4.7 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: poetry/1.1.6 CPython/3.9.5 Linux/5.12.11-300.fc34.x86_64

File hashes

Hashes for kafka_bridge_client-0.1.1-py3-none-any.whl
Algorithm Hash digest
SHA256 cc8acfc958925043aef32a8446a4479867b0b3caee51f76f38005f13db4c484c
MD5 ad4d02fff660d2710575de311c439b37
BLAKE2b-256 c7f2dd860d37db9b3a44dcbc9c03ed075066ee25a8f71f0c3790ef94c6d6f683

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