Kafkacrypto

Latest version: v0.9.11.1

Safety actively analyzes 723650 Python packages for vulnerabilities to keep your Python projects secure.

Scan your dependencies

Page 3 of 7

0.9.9.12

Not secure
This is a bufix release. Changes:

* Enhance AtomicFile fsync behavior on Mac platforms to use FULLSYNC to ensure data is committed to stable storage.
* Enhance AtomicFile to use exclusive locking to harmonize errors between linux/bsd/unix and windows.
* Enhance AtomicFile to flush directory metadata to reduce time to atomic operation being on stable storage.
* Add close operations to KafkaCrypto, Ratchet, KeyGenerator, and KafkaCryptoStore. Allows reuse of a single config file in different unit tests from a single process.

Only the first of these fixes an issue that had potential to result in data corruption (and only on Mac platforms). Two round trip tests are also now public.

0.9.9.11

Not secure
This maintenance releases fixes a number of bugs:

- Fixes the FutureRecordMetadata implementation in confluent_kafka_wrapper to be functional
- Avoid initializing the root logger on package import by switching from logging to warnings in __init__.py
- Added logging and timeout fixes in confluent_kafka_wrapper
- Prevent management thread exits on recoverable errors
- Fix bug that was present in all public versions of Kafkacrypto that prevented direct producer-to-consumer key exchanges without controller interaction.

0.9.9.11a1

Not secure

0.9.9.11a0

Not secure

0.9.9.10

Not secure
This version fixes a bug in the new flush implementation in confluent_kafka_wrapper that was necessary to work around an issue in librdkafka. Unfortunately, the original implementation did not respect being multi-threaded safe, and would thus encounter scenarios where flush would never return. Fix that by properly checking the number of messages remaining to be produced, in addition to tracking the number of messages produced within each thread calling poll. Also adds a timeout to all flush calls to reduce the impact of any such related bugs.

0.9.9.9

Not secure
This version adds compatibility for Python 3.10, and adds a work-around for a nasty bug in librdkafka 1.8.0 (persists up to at least 1.8.2) that caused an inability to send subscribe messages and (eventually) resulted in memory corruption and a crash of the management thread.

Page 3 of 7

© 2025 Safety CLI Cybersecurity Inc. All Rights Reserved.