Contents

kafka 1.3.5

0

Pure Python client for Apache Kafka

Pure Python client for Apache Kafka

Stars: 5599, Watchers: 5599, Forks: 1406, 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 5599 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
No  kafka  pypi packages just yet.

Errors

A list of common kafka errors.

Code Examples

Here are some kafka code examples and snippets.

GitHub Issues

The kafka 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

Related Packages & Articles