kafka-python 2.0.2

Pure Python client for Apache Kafka

Stars: 5597, Watchers: 5597, Forks: 1404, Open Issues: 313

The dpkp/kafka-python repo was created 12 years ago and the last code push was 2 months ago.
The project is extremely popular with a mindblowing 5597 github stars!

How to Install kafka-python

You can install kafka-python using pip

pip install kafka-python

or add it to a project with poetry

poetry add kafka-python

Package Details

Author

Dana Powers

License

Apache License 2.0

Homepage

https://github.com/dpkp/kafka-python

PyPi:

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

GitHub Repo:

https://github.com/dpkp/kafka-python

Classifiers

• Software Development/Libraries/Python Modules

Related Packages

Errors

A list of common kafka-python errors.

Code Examples

Here are some kafka-python code examples and snippets.

GitHub Issues

The kafka-python package has 313 open issues on GitHub

• Fix crc32c's main for Python 3
• is master branch stable?
• Fix a link to snappy
• Fix the link to the compatibility page
• Can I use poll and iterate in kafka-python together?
• fix: add chain_future to send method
• future.py Future is not thread safe，may loss callback
• is kafka-python deprecated?
• Kafka 3.0 Kraft support?
• Broker advertised listeners hostname is clobbered after KafkaProducer is initialized
• KafkaProducer cannot send data standalone
• "Timeout to send to wakeup socket!" when trying to describe consumer group
• Support AWS_MSK_IAM authentication
• Kafka consumer stuck after timeout
• Consumption with poll looses some (~30%) of messages forever

See more issues on GitHub