kafka 1.3.5

Pure Python client for Apache Kafka

Stars: 5493, Watchers: 5493, Forks: 1381, Open Issues: 304

The dpkp/kafka-python repo was created 11 years ago and the last code push was an hour ago.
The project is extremely popular with a mindblowing 5493 github stars!

How to Install kafka

You can install kafka using pip

pip install kafka

or add it to a project with poetry

poetry add kafka

Package Details

Author

Dana Powers

License

Apache License 2.0

Homepage

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

PyPi:

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

GitHub Repo:

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

Classifiers

• Software Development/Libraries/Python Modules

Related Packages

Errors

A list of common kafka errors.

Code Examples

Here are some kafka code examples and snippets.

GitHub Issues

The kafka package has 304 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