lib/waterdrop/config.rb in waterdrop-2.6.7 vs lib/waterdrop/config.rb in waterdrop-2.6.8
- old
+ new
@@ -62,9 +62,14 @@
# dispatch previously buffered messages.
setting :wait_backoff_on_queue_full, default: 0.1
# option [Numeric] how many seconds should we wait with the backoff on queue having space for
# more messages before re-raising the error.
setting :wait_timeout_on_queue_full, default: 10
+
+ setting :wait_backoff_on_transaction_command, default: 0.5
+
+ setting :max_attempts_on_transaction_command, default: 5
+
# option [Boolean] should we send messages. Setting this to false can be really useful when
# testing and or developing because when set to false, won't actually ping Kafka but will
# run all the validations, etc
setting :deliver, default: true
# option [Class] class for usage when creating the underlying client used to dispatch messages