******************** 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.
3.3.0
******************** Changed ======= * Added/removed some custom attributes used for monitoring. Search for custom_attribute_name annotations for details.
3.2.0
******************** Changed ======= * Add timestamp parameter for consumer, allowing the starting offset for consuming to be overridden from the default.
3.1.0
********************
Added ===== * A variety of custom attributes are now set for monitoring purposes. Search for custom_attribute_name annotations for details.
Changed ======= * Error recording to the log will now include message details when the message is available on the error.