Hi everyone, Yesterday Parse.ly released PyKafka <https://github.com/Parsely/pykafka> 2.8.0, which has been in the works since January. For those not familiar, PyKafka is a pure-Python client for Kafka that maintains a programmer-friendly API and offers optional integration with the librdkafka C client for enhanced performance. Check out the release notes for 2.8.0 <https://github.com/Parsely/pykafka/releases/tag/2.8.0>, and install PyKafka with pip install pykafka.
Here's a high-level overview of some of the most exciting changes in this release: - Support for user-defined SerDes to simplify the handling of custom message payload formats - Decoupling of the "committed" and "consumed" concepts to allow granular management of offsets in client code - Implementation of non-busy waiting in the Producer - Tons of bugfixes As always, please feel free to reach out with questions or comments about PyKafka via the mailing list or the GitHub repo. -- Emmett Butler | Senior Software Engineer <http://www.parsely.com/?utm_source=Signature&utm_medium=emmett-butler&utm_campaign=Signature>