confluent-kafka 2.13.0

Confluent's Python client for Apache Kafka

Stars: 446, Watchers: 446, Forks: 938, Open Issues: 198

The confluentinc/confluent-kafka-python repo was created 9 years ago and the last code push was 9 hours ago.
The project is popular with 446 github stars!

How to Install confluent-kafka

You can install confluent-kafka using pip

pip install confluent-kafka

or add it to a project with poetry

poetry add confluent-kafka

Package Details

Author

None

License

None

Homepage

None

PyPi:

https://pypi.org/project/confluent-kafka/

GitHub Repo:

https://github.com/confluentinc/confluent-kafka-python

Classifiers

• Software Development/Libraries/Python Modules

Related Packages

Errors

A list of common confluent-kafka errors.

Code Examples

Here are some confluent-kafka code examples and snippets.

GitHub Issues

The confluent-kafka package has 198 open issues on GitHub

• Schema references deserialization fails in versions >= 2.8.2
• AIOProducer doesn't work with OAUTHBEARER/oauth_cb
• Expose schema metadata in AvroDeserializer (Issue #2046)Fix/avro deserializer schema info
• Version 2.13.0 blocks in SerializingProducer constructor
• feat: add paused() method to Consumer
• Add deprecation warning for AvroProducer and AvroConsumer in README
• [Version 2.2.0] list_topics() messes up offsets
• Add Free-Threaded Python Support in 3.14
• Avro Deserializer does not return any schema information - how to deal with RecordNameStrategy etc?
• describe_acls() is very slow and crashes with segmentation fault for large ACL sets (>55k entries)
• chore(deps): update minor+patch dependencies (master)
• When consumer is paused check if it's paused
• String representation of a TopicPartition raises a SystemError on Windows with Python 3.12.1 and Confluent Kafka Python 2.3.0
• Fix typo
• Add Consumer.io_event_enable

See more issues on GitHub