Edx-event-bus-kafka

Latest version: v5.7.0

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

Scan your dependencies

Page 5 of 11

3.6.1

********************
Fixed
=======
* Added a poll call to force resets to be processed during replay/offset-reset mode.

3.6.0

********************
Changed
=======
* Consumers do not consume events after resetting offsets.

3.5.1

********************
Fixed
=====
* Convert timestamps to millisecond offsets as expected by the Kafka API when replaying by timestamp in the consumer

3.5.0

********************
Added
=====
* New setting ``EVENT_BUS_KAFKA_CONSUMER_CONSECUTIVE_ERRORS_LIMIT`` will terminate the consumer if too many errors occur in a row, supporting an automated version of "have you tried turning it off and on again" (as long as consumer will automatically be restarted e.g. by Kubernetes).

3.4.1

********************
Fixed
=====
* Fixed bugs in the event replay/offset handling code for consumers.

3.4.0

********************
Changed
=======
* Kill infinite consumer loop when we see a fatal KafkaError, as recommended in the documentation. See https://github.com/confluentinc/librdkafka/blob/e0b9e92a0b492b5b1a6f1bcf08744928d45bf396/INTRODUCTION.md#fatal-consumer-errors.

Page 5 of 11

© 2024 Safety CLI Cybersecurity Inc. All Rights Reserved.