Buradasın

Python Kafka Client Overview

Yapay zekadan makale özeti

General Information: Confluent provides confluent-kafka-python package for Kafka compatibility
Client is built on top of librdkafka library
Compatible with Kafka brokers 0.8+ and Confluent platforms
Installation: Available on PyPI via pip
Can be installed globally or in virtualenv
Includes pre-built librdkafka without GSSAPI/Kerberos support
Producer Features: Supports asynchronous and synchronous message sending
Provides callback for delivery notifications
Offers flush() method for synchronous writes
Consumer Features: Requires group.id configuration for consumer membership
Supports manual offset commits with asynchronous option
Includes basic poll loop functionality
FIPS Compliance: Requires OpenSSL 3.0 for FIPS-compliant communication
Can be installed via prebuilt wheels or source build
Needs FIPS provider module and configuration
Delivery Guarantees: Default "None" guarantee may result in data loss
"At least once" guarantee available through manual offset storage
Asynchronous commits provide immediate response