Sha256: 5b224069215b06c0257184fb9d1180f92020708152ac7daf5db1edaf1e241240
Contents?: true
Size: 667 Bytes
Versions: 18
Compression:
Stored size: 667 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Schemas
# Consumer group topic validation rules
ConsumerGroupTopic = Dry::Validation.Schema do
required(:id).filled(:str?, format?: Karafka::Schemas::TOPIC_REGEXP)
required(:name).filled(:str?, format?: Karafka::Schemas::TOPIC_REGEXP)
required(:backend).filled(included_in?: %i[inline sidekiq])
required(:consumer).filled
required(:parser).filled
required(:max_bytes_per_partition).filled(:int?, gteq?: 0)
required(:start_from_beginning).filled(:bool?)
required(:batch_consuming).filled(:bool?)
required(:persistent).filled(:bool?)
end
end
end
Version data entries
18 entries across 18 versions & 1 rubygems