v2.6.1.beta1

• [Refactor] Remove no longer needed patches.
• [Fix] Fork detection on a short lived processes seems to fail. Clear the used parent process client reference not to close it in the finalizer (#356).
• [Change] Require karafka-rdkafka >= 0.13.0.beta2.
• [Change] Require 'karafka-core' >= 2.1.0

v2.6.0

• [Improvement] Introduce client_class setting for ability to replace underlying client with anything specific to a given env (dev, test, etc).
• [Improvement] Introduce Clients::Buffered useful for writing specs that do not have to talk with Kafka (id-ilych)
• [Improvement] Make #produce method private to avoid confusion and make sure it is not used directly (it is not part of the official API).
• [Change] Change wait_on_queue_full from false to true as a default.
• [Change] Rename wait_on_queue_full_timeout to wait_backoff_on_queue_full to match what it actually does.
• [Enhancement] Introduce wait_timeout_on_queue_full with proper meaning. That is, this represents time after which despite backoff the error will be raised. This should allow to raise an error in case the backoff attempts were insufficient. This prevents from a case, where upon never deliverable messages we would end up with an infinite loop.
• [Fix] Provide type for queue full errors that references the appropriate public API method correctly.

v2.5.3

• Require karafka-core 2.0.13
• Include topic name in the error.occurred notification payload.
• Include topic name in the message.acknowledged notification payload.

v2.5.2

[Fix] Require missing Pathname (#345)

v2.5.1

• [Feature] Introduce a configurable backoff upon librdkafka queue full (false by default).

v2.5.0

• [Feature] Pipe all the errors including synchronous errors via the error.occurred.
• [Improvement] Pipe delivery errors that occurred not via the error callback using the error.occurred channel.
• [Improvement] Introduce WaterDrop::Errors::ProduceError and WaterDrop::Errors::ProduceManyError for any inline raised errors that occur. You can get the original error by using the #cause.
• [Improvement] Include #dispatched messages handler in the WaterDrop::Errors::ProduceManyError error, to be able to understand which of the messages were delegated to librdkafka prior to the failure.
• [Maintenance] Remove the WaterDrop::Errors::FlushFailureError in favour of correct error that occurred to unify the error handling.
• [Maintenance] Rename Datadog::Listener to Datadog::MetricsListener to align with Karafka (#329).
• [Fix] Do not flush when there is no data to flush in the internal buffer.
• [Fix] Wait on the final data flush for short-lived producers to make sure, that the message is actually dispatched by librdkafka or timeout.

v2.4.11

• Replace the local rspec locator with generalized core one.
• Make ::WaterDrop::Instrumentation::Notifications::EVENTS list public for anyone wanting to re-bind those into a different notification bus.

v2.4.10

• Include caller in the error instrumentation to align with Karafka.

v2.4.9

• Remove empty debug logging out of LoggerListener.
• Do not lock Ruby version in Karafka in favour of karafka-core.
• Make sure karafka-core version is at least 2.0.9 to make sure we run karafka-rdkafka.

v2.4.8

• Use monotonic time from Karafka core.