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