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(:controller).filled
      required(:parser).filled
      required(:max_bytes_per_partition).filled(:int?, gteq?: 0)
      required(:start_from_beginning).filled(:bool?)
      required(:batch_processing).filled(:bool?)
      required(:persistent).filled(:bool?)
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
karafka-1.0.1	lib/karafka/schemas/consumer_group_topic.rb