Adc-streaming

Latest version: v2.4.0

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

Scan your dependencies

Page 1 of 2

2.4.0

This minor release exposes two new capabilities: to read from a specific time or logical offset and to publish to multiple topics using a single `Producer` object.

What's Changed
* Allow specifying logical offset or datetime start position on Consumer.stream() by alchzh in https://github.com/astronomy-commons/adc-streaming/pull/65
* Multi-topic publishing by cnweaver in https://github.com/astronomy-commons/adc-streaming/pull/69 . Users can continue to specify a single topic when constructing a `Producer` and have calls to `write()` automatically send messages to that topic, or can now specify the target topic when calling `write()`.

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

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.

Page 1 of 2

© 2024 Safety CLI Cybersecurity Inc. All Rights Reserved.