Sha256: af40cca5ed26419a1752f1776c792eec1bc916061200fa100cb197765a4a88a9
Contents?: true
Size: 1011 Bytes
Versions: 9
Compression:
Stored size: 1011 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Routing
module Features
class Eofed < Base
# Eofed related contracts namespace
module Contracts
# Contract for eofed topic setup
class Topic < Karafka::Contracts::Base
configure do |config|
config.error_messages = YAML.safe_load(
File.read(
File.join(Karafka.gem_root, 'config', 'locales', 'errors.yml')
)
).fetch('en').fetch('validations').fetch('topic')
end
nested :eofed do
required(:active) { |val| [true, false].include?(val) }
end
virtual do |data, errors|
next unless errors.empty?
eofed = data[:eofed]
next unless eofed[:active]
next if data[:kafka][:'enable.partition.eof']
[[%i[eofed kafka], :enable]]
end
end
end
end
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems