Adc-streaming

Latest version: v2.3.2

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

Scan your dependencies

Page 1 of 2

2.3.2

This is a bug-fix release which updates the list of compatible dependency versions to avoid recent versions of librdkafka/confluent-kafka with known communications problems.

What's Changed
* Update confluent-kafka version to skip recent buggy releases by lpsinger in https://github.com/astronomy-commons/adc-streaming/pull/67
* Update doc strings and comments for confluent-kafka workarounds by lpsinger in https://github.com/astronomy-commons/adc-streaming/pull/68


**Full Changelog**: https://github.com/astronomy-commons/adc-streaming/compare/v2.3.1...v2.3.2

2.3.1

This is a bug-fix release which reverts to using no compression by default when sending messages. Advanced users who wish to use compression can continue to do so by configuring the `compression_type` `ProducerConfig` option.

2.3.0

This release adds new minor features (thanks to lpsinger), but is otherwise fully interface backwards-compatible:
- [61](https://github.com/astronomy-commons/adc-streaming/pull/61): Enable Zstd compression of messages by default, with the option to choose any compression method supported by Apache Kafka.
- [62](https://github.com/astronomy-commons/adc-streaming/pull/62): Add the option to adjust the producer `message.max.bytes`. This can be important to be able to send messages larger than the default maximum, when the configured maximum on the broker is also larger than the default.

2.2.0

This release includes bug fixes and improvements since v2.1.0:
- [60](https://github.com/astronomy-commons/adc-streaming/pull/60): The build system has been updated with a `pyproject.toml` file.
- [58](https://github.com/astronomy-commons/adc-streaming/pull/58): `adc.Consumer` now supports a `stop` method which can be used to end the `stream` loop conveniently from another thread.
- [55](https://github.com/astronomy-commons/adc-streaming/pull/55): `adc.Consumer._stream_forever` handles errors raised by librdkafka better.

2.1.0

This release includes https://github.com/astronomy-commons/adc-streaming/pull/53 by lpsinger which enables the new(ly enhanced) OIDC authentication mechanism supported by the latest ([version 3.1.0](https://downloads.apache.org/kafka/3.1.0/RELEASE_NOTES.html)) Apache Kafka release. When not using this new feature this release remains compatible with older Kafka versions.

Also included is a bug-fix to avoid crashing when attempting to read a topic with multiple partitions 'to its end' while new messages are being actively published.

1.2.0

This release includes 43, which adds more detail to the `adc.errors.KafkaException` class by exposing the low-level `confluent_kafka.KafkaError` directly on the exception so that callers can make judgements about the retriability of errors.

Page 1 of 2

© 2024 Safety CLI Cybersecurity Inc. All Rights Reserved.