Releases
v2.3.0
[Feature] Introduce Exactly-Once Semantics within consumers #transaction
block (Pro)
[Feature] Provide ability to multiplex subscription groups (Pro)
[Feature] Provide Karafka::Admin::Acl
for Kafka ACL management via the Admin APIs.
[Feature] Periodic Jobs (Pro)
[Feature] Offset Metadata storage (Pro)
[Feature] Provide low-level listeners management API for dynamic resources scaling (Pro)
[Enhancement] Improve shutdown process by allowing for parallel connections shutdown.
[Enhancement] Introduce non_blocking
routing API that aliases LRJ to indicate a different use-case for LRJ flow approach.
[Enhancement] Allow to reset offset when seeking backwards by using the reset_offset
keyword attribute set to true
.
[Enhancement] Alias producer operations in consumer to skip #producer
reference.
[Enhancement] Provide an :independent
configuration to DLQ allowing to reset pause count track on each marking as consumed when retrying.
[Enhancement] Remove no longer needed shutdown patches for librdkafka
improving multi-sg shutdown times for cooperative-sticky
.
[Enhancement] Allow for parallel closing of connections from independent consumer groups.
[Enhancement] Provide recovery flow for cases where DLQ dispatch would fail.
[Change] Make Kubernetes::LivenessListener
not start until Karafka app starts running.
[Change] Remove the legacy "inside of topics" way of defining subscription groups names
[Change] Update supported instrumentation to report on #tick
.
[Refactor] Replace define_method
with class_eval
in some locations.
[Fix] Fix a case where internal Idle job scheduling would go via the consumption flow.
[Fix] Make the Iterator #stop_partition
work with karafka-rdkafka 0.14.6
.
[Fix] Ensure Pro components are not loaded during OSS specs execution (not affecting usage).
[Fix] Fix invalid action label for consumers in DataDog logger instrumentation.
[Fix] Fix a scenario where Karafka::Admin#seek_consumer_group
would fail because reaching not the coordinator.
[Ignore] option --include-consumer-groups not working as intended after removal of "thor"
You can’t perform that action at this time.