Sha256: d2670be0240ce521d8810644954a1076435c5dd7d9a5e7831df4c8e93f0eaf4b
Contents?: true
Size: 684 Bytes
Versions: 27
Compression:
Stored size: 684 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Contracts
# Consumer group topic validation rules
class ConsumerGroupTopic < Dry::Validation::Contract
params do
required(:id).filled(:str?, format?: Karafka::Contracts::TOPIC_REGEXP)
required(:name).filled(:str?, format?: Karafka::Contracts::TOPIC_REGEXP)
required(:backend).filled(included_in?: %i[inline sidekiq])
required(:consumer).filled
required(:deserializer).filled
required(:max_bytes_per_partition).filled(:int?, gteq?: 0)
required(:start_from_beginning).filled(:bool?)
required(:batch_consuming).filled(:bool?)
end
end
end
end
Version data entries
27 entries across 27 versions & 1 rubygems