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