lib/karafka/pro/routing/features/dead_letter_queue/contract.rb in karafka-2.0.23 vs lib/karafka/pro/routing/features/dead_letter_queue/contract.rb in karafka-2.0.24

- old
+ new

@@ -19,12 +19,12 @@ # Extended rules for dead letter queue settings class Contract < Contracts::Base configure do |config| config.error_messages = YAML.safe_load( File.read( - File.join(Karafka.gem_root, 'config', 'errors.yml') + File.join(Karafka.gem_root, 'config', 'locales', 'pro_errors.yml') ) - ).fetch('en').fetch('validations').fetch('pro_topic') + ).fetch('en').fetch('validations').fetch('topic') end # Make sure that we don't use DLQ with VP # Using those two would cause many issues because the offset within VP is not # manageable so in scenarios where we would fail on the last message, we would move by