lib/karafka/pro/processing/strategies/dlq/vp.rb in karafka-2.0.39 vs lib/karafka/pro/processing/strategies/dlq/vp.rb in karafka-2.0.40

- old
+ new

@@ -19,10 +19,11 @@ # Dead Letter Queue enabled # Virtual Partitions enabled # # In general because we collapse processing in virtual partitions to one on errors, there # is no special action that needs to be taken because we warranty that even with VPs - # on errors a retry collapses into a single state. + # on errors a retry collapses into a single state and from this single state we can + # mark as consumed the message that we are moving to the DLQ. module Vp # Features for this strategy FEATURES = %i[ dead_letter_queue virtual_partitions