pykafka
pykafka copied to clipboard
Parsely
Apache Kafka client for Python; high-level & low-level consumer/producer, with great performance.
we have a kafka cluster with 5 nodes, and producer gen through method 'get_producer', when we restart one node, the producer got error message bellow: - pykafka.OwnedBroker.queue_reader for broker 4]...
I'm use the get_balanced_consumer, and start 50 threading,the lag is too high  
HI i tried with multiple docker images like Ubuntu and python:3.8-alpine etc.. and everywhere I am getting an error as below while trying to connect to my kafka cluster (2.7)...
Bumps [pytest](https://github.com/pytest-dev/pytest) from 4.6.2 to 6.2.2. Release notes Sourced from pytest's releases. 6.2.2 pytest 6.2.2 (2021-01-25) Bug Fixes #8152: Fixed "(<Skipped instance>)" being shown as a skip reason in the...
![dependabot-preview[bot] avatar](https://avatars.githubusercontent.com/in/2141?v=4 "dependabot-preview[bot] avatar"){kind=avatar}
Bumps [lz4](https://github.com/python-lz4/python-lz4) from 2.1.10 to 3.1.3. Release notes Sourced from lz4's releases. Publish wheels for Python 3.9 This release adds support for publishing wheels to PyPi for Python 3.9. Wheel...
Bumps [parameterized](https://github.com/wolever/parameterized) from 0.7.0 to 0.8.1. Changelog Sourced from parameterized's changelog. 0.8.1 (2021-01-09) * Add README and LICENSE to pypi sdist package (wolever/parameterized#114; thanks @chohner) 0.8.0 (2021-01-04) * Handle camelCase...
when i boot my django project,the console will print as follow errors: ``` Exception AttributeError: "'NoneType' object has no attribute 'info'" in ignored ``` **PyKafka version**: **2.8.0** **Kafka version**: **2.1.1**...
Saw this issue that really helped me address the same error I had with Producer.produce not taking strings: https://github.com/Parsely/pykafka/issues/759 Please fix the READMME to reflect this. Thanks.
I know that one might require upper version level bounds if the APIs of dependencies change, but this would enormously help with packaging for Linux distributions :).
SASL Support
I would like to use pykafka to connect to IBM Bluemix Message Hub with is a Kafka implementation. There is a kafka-python example in this thread. https://stackoverflow.com/questions/35294949/can-i-call-the-bluemix-message-hub-service-from-python/40325181#40325181 I also found...
