Update dependency karafka to v2.4.16

[renovate]

This PR contains the following updates:

Package	Change	Age	Adoption	Passing	Confidence
karafka (source, changelog)	2.4.7 -> 2.4.16

---

Release Notes

karafka/karafka (karafka)

v2.4.16

Compare Source

• [Enhancement] Improve post-rebalance revocation messages filtering.
• [Enhancement] Introduce Consumer#wrap for connection pooling management and other wrapped operations.
• [Enhancement] Guard transactional operations from marking beyond assignment ownership under some extreme edge-cases.
• [Enhancement] Improve VPs work with transactional producers.
• [Enhancement] Prevent non-transactional operations leakage into transactional managed offset management consumers.
• [Fix] Prevent transactions from being marked with a non-transactional default producer when automatic offset management and other advanced features are on.
• [Fix] Fix kafka_format KeyError that occurs when a non-hash is assigned to the kafka scope of the settings.
• [Fix] Non cooperative-sticky transactional offset management can refetch reclaimed partitions.

v2.4.15

Compare Source

• [Fix] Assignment tracker current state fetch during a rebalance loop can cause an error on multi CG setup.
• [Fix] Prevent double post-transaction offset dispatch to Kafka.

v2.4.14

Compare Source

• [Enhancement] Improve low-level critical error reporting.
• [Enhancement] Expand Kubernetes Liveness state reporting with critical errors detection.
• [Enhancement] Save several string allocations and one array allocation on each job execution when using Datadog instrumentation.
• [Enhancement] Support eofed jobs in the AppSignal instrumentation.
• [Enhancement] Allow running bootfile-less Rails setup Karafka CLI commands where stuff is configured in the initializers.
• [Fix] Instrumentation::Vendors::Datadog::LoggerListener treats eof jobs as consume jobs.

v2.4.13

Compare Source

• [Enhancement] Make declarative topics return different exit codes on migrable/non-migrable states (0 - no changes, 2 - changes) when used with --detailed-exitcode flag.
• [Enhancement] Introduce config.strict_declarative_topics that should force declaratives on all non-pattern based topics and DLQ topics
• [Enhancement] Report ignored repartitioning to lower number of partitions in declarative topics.
• [Enhancement] Promote the LivenessListener#healty? to a public API.
• [Fix] Fix Karafka::Errors::MissingBootFileError when debugging in VScode with ruby-lsp.
• [Fix] Require karafka-core >= 2.4.4 to prevent dependencies conflicts.
• [Fix] Validate swarm cli and always parse options from argv (roelbondoc)

v2.4.12

Compare Source

• [Feature] Provide Adaptive Iterator feature as a fast alternative to Long-Running Jobs (Pro).
• [Enhancement] Provide Consumer#each as a delegation to messages batch.
• [Enhancement] Verify cancellation request envelope topic similar to the schedule one.
• [Enhancement] Validate presence of bootstrap.servers to avoid incomplete partial reconfiguration.
• [Enhancement] Support ActiveJob#enqueue_at via Scheduled Messages feature (Pro).
• [Enhancement] Introduce Karafka::App#debug! that will switch Karafka and the default producer into extensive debug mode. Useful for CLI debugging.
• [Enhancement] Support full overwrite of the BaseConsumer#producer.
• [Enhancement] Transfer the time of last poll back to the coordinator for more accurate metrics tracking.
• [Enhancement] Instrument Consumer#seek via consumer.consuming.seek.
• [Fix] Fix incorrect time reference reload in scheduled messages.

v2.4.11

Compare Source

• [Enhancement] Validate envelope target topic type for Scheduled Messages.
• [Enhancement] Support for enqueue_after_transaction_commit in rails active job.
• [Fix] Fix invalid reference to AppSignal version.

v2.4.10

Compare Source

• [Feature] Provide Kafka based Scheduled Messages to be able to send messages in the future via a proxy topic.
• [Enhancement] Introduce a #assigned hook for consumers to be able to trigger actions when consumer is built and assigned but before first consume/ticking, etc.
• [Enhancement] Provide Karafka::Messages::Message#tombstone? to be able to quickly check if a message is a tombstone message.
• [Enhancement] Provide more flexible API for Recurring Tasks topics reconfiguration.
• [Enhancement] Remove no longer needed Rails connection releaser.
• [Enhancement] Update AppSignal client to support newer versions (tombruijn and hieuk09).
• [Fix] Fix a case where there would be a way to define multiple subscription groups for same topic with different consumer.

v2.4.9

Compare Source

• [Feature] Provide Kafka based Recurring (Cron) Tasks.
• [Enhancement] Wrap worker work with Rails Reloader/Executor (fusion2004)
• [Enhancement] Allow for partial topic level kafka scope settings reconfiguration via inherit flag.
• [Enhancement] Validate eof kafka scope flag when eofed in routing enabled.
• [Enhancement] Provide mark_after_dispatch setting for granular DLQ marking control.
• [Enhancement] Provide Karafka::Admin.rename_consumer_group.

v2.4.8

Compare Source

• [Feature] Introduce ability to react to #eof either from #consume or from #eofed when EOF without new messages.
• [Enhancement] Provide Consumer#eofed? to indicate reaching EOF.
• [Enhancement] Always immediately report on inconsistent_group_protocol error.
• [Enhancement] Reduce virtual partitioning to 1 partition when any partitioner execution in a partitioned batch crashes.
• [Enhancement] Provide KARAFKA_REQUIRE_RAILS to disable default Rails require to run Karafka without Rails despite having Rails in the Gemfile.
• [Enhancement] Increase final listener recovery from 1 to 60 seconds to prevent constant rebalancing. This is the last resort recovery and should never happen unless critical errors occur.

---

Configuration

📅 Schedule: Branch creation - At any time (no schedule defined), Automerge - At any time (no schedule defined).

🚦 Automerge: Disabled by config. Please merge this manually once you are satisfied.

♻ Rebasing: Whenever PR is behind base branch, or you tick the rebase/retry checkbox.

🔕 Ignore: Close this PR and you won't be reminded about this update again.

---

• If you want to rebase/retry this PR, check this box

---

This PR was generated by Mend Renovate. View the repository job log.