karafka/waterdrop

Issues

• Dispatched collection in the ProduceManyError contains DeliveryHandle and DeliveryReport

  #518 opened 3 months ago by ujasur
  3

• Improve transactional spec stability

  #522 opened 2 months ago by mensfeld
  0

• Dependency Dashboard

  #343 opened 2 years ago by renovate
  0

• Replace the `throw(:abort)` API with direct `WaterDrop::AbortTransaction` error

  #513 opened 3 months ago by mensfeld
  1

• Consumer consuming error: Local: Erroneous state (state) post break flow in transaction

  #511 opened 3 months ago by mensfeld
  0

• Raise an exception when using return/break/next in a transactional code block similar to Rails 8

  #512 opened 3 months ago by mensfeld
  0

• Transactional sync producer raises a 'Purged in queue' exception when producing messages via the same producer that previously failed to produce messages

  #501 opened 4 months ago by Aerdayne
  6

• Wait timeout bypassed on unreachable cluster

  #502 opened 4 months ago by Aerdayne
  8

• Implementation to report topic level statistics

  #495 opened 4 months ago by YadhuPrakash
  0

• Check if variants can work with idempontents on and acks changes. If not, validate similar to transactional alterations to ack

  #491 opened 4 months ago by mensfeld
  0

• Provide `#idempotent?` similar to `#transactional?`

  #489 opened 4 months ago by mensfeld
  0

• Enhance AppSignal and DataDog instrumentation with transactional metrics (when used)

  #490 opened 4 months ago by mensfeld
  0

• Provide alias to `#with` named `#variant`

  #487 opened 5 months ago by mensfeld
  0

• Support getting partition count data from producer for custom partitioners

  #442 opened 5 months ago by mensfeld
  1

• Middleware runs twice when using buffered produce

  #474 opened 5 months ago by darthryking
  0

• Document `instrument_on_wait_queue_full` in the docs on retries

  #459 opened 6 months ago by mensfeld
  0

• Transactional producer config not aligned by default

  #465 opened 6 months ago by mensfeld
  0

• Revisit the librdkafka `delivery.timeout.ms` vs. max wait time

  #456 opened 7 months ago by mensfeld
  0

• Switch all settings to use ms instead of seconds

  #332 opened 7 months ago by mensfeld
  0

• Introduce `instrument_on_wait_queue_full` for ability to disable instrumentation on non-critical queue full errors

  #457 opened 7 months ago by mensfeld
  0

• Trying to understand recommendation against at_exit

  #455 opened 8 months ago by jlambert121
  2

• Produce lifecycle events similar to karafka

  #450 opened 8 months ago by mensfeld
  0

• Document possibility of using partitions count for custom partitioners

  #444 opened 8 months ago by mensfeld
  0

• Support transactional offset metadata storage

  #438 opened 9 months ago by mensfeld
  0

• Provide ability to pass trace_id (name tba) when producing to use within the delivery handler and report

  #429 opened 9 months ago by mensfeld
  1

• Make WaterDrop Buffered `#messages_for` return arrah instead of `nil` when nothing dispatched

  #410 opened a year ago by mensfeld
  1

• Expand instrumentation views in DD with scale (ms vs micro)

  #409 opened a year ago by mensfeld
  0

• Buffered client transactions on abort store messages in the internal accu

  #405 opened a year ago by mensfeld
  0

• Make dummy and buffer clients return incremental offsets

  #406 opened a year ago by mensfeld
  0

• Do not publish error messages on purged messages that were part of an aborted transaction (if possible)

  #402 opened a year ago by mensfeld
  0

• Commit transaction should not kick in when transaction is aborted

  #399 opened a year ago by mensfeld
  0

• Allow waterdrop to use topic as a symbol or a string

  #382 opened a year ago by mensfeld
  0

• Expose `#flush`, `#purge` and `#close!` (combination of those) once karafka-rdkafka released

  #393 opened a year ago by mensfeld
  0

• Move payload reporting into debug for logger

  #375 opened a year ago by mensfeld
  0

• Errors raised during `produce_sync` and `produce_async` via monitor missing root cause.

  #370 opened a year ago by konalegi
  2

• Improve error reporting - include cause in the BaseError#inspect

  #367 opened a year ago by knovoselic
  0

• NoMethodError: undefined method `name' for #<Rdkafka::Producer:0x0000562d3d2e5d18>

  #365 opened a year ago by RachelSa
  3

• Close mutex on heavily async does not prevent post-close call

  #360 opened a year ago by mensfeld
  0

• Fork detection on a short lived processes seems to fail

  #356 opened a year ago by mensfeld
  1

• Regenerate UUIDs of forked processes

  #357 opened a year ago by mensfeld
  1

• Waterdrop 2.6.0 Upgrade RSpec Error

  #355 opened a year ago by hunzinker
  1

• `karafka-rdkafka` is allowed to be less than `0.12.3` with most recent WaterDrop version

  #350 opened a year ago by hunzinker
  10

• Allow builder to accept explicit client

  #347 opened a year ago by mensfeld
  0

• Once rdkafka-ruby 1.0 released, remove the flush patches

  #340 opened a year ago by mensfeld
  1

• Set retry on queue to true by default in 2.6.0

  #335 opened a year ago by mensfeld
  0

• Make `#produce` method private to avoid confusion

  #351 opened a year ago by mensfeld
  0

• If there is any topic/message related information, include it in the 'error.occurred' event

  #328 opened a year ago by alinagrishchuk
  1

• Pathname not visible because not required in WaterDrop

  #345 opened a year ago by mensfeld
  0

• Retry dispatch after a backoff upon queue full

  #333 opened 2 years ago by mensfeld
  0

• Align DD metrics listener with Karafka metrics listener

  #329 opened 2 years ago by mensfeld
  0