confluent-kafka 2.3.0

Confluent's Python client for Apache Kafka

Stars: 3617, Watchers: 3617, Forks: 873, Open Issues: 264

The confluentinc/confluent-kafka-python repo was created 7 years ago and the last code push was 9 hours ago.
The project is very popular with an impressive 3617 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

Confluent Inc

License

Homepage

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

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 264 open issues on GitHub

• Update Jenkinsfile to use maven settings helper
• updated readme code example
• consumer not poll message and GroupCoordinator disconnect
• Use function consume lost message after call seek
• Potential memory leaks?
• warning: "Please migrate your Python Protobuf producers and consumers to 'use.deprecated.format':True"
• [DO NOT MERGE] [TEST] Add .circleci/config.yml
• fix order of param
• Partitioner does not work with one message instance Producer
• Unable to use confluent-kafka with Apple M1 Pro
• Failed to create topic error code val=-197
• avro_producer example is broken
• Wrong signature in docstring
• install on RED HAT with python3 with GSSAPI/Kerberos support
• Consumer doesn't raise error if "group.id" is a non-string, also doesn't get messages

See more issues on GitHub