Module: Sbmt::KafkaConsumer::Types

Defined in:

lib/sbmt/kafka_consumer/types.rb

Constant Summary

Regexp =

Types.Nominal(::Regexp).constructor do |input|
  if input.is_a?(::String)
    ::Regexp.new(input)
  else
    input
  end
end

ConfigAttrs =

Dry::Types["hash"].constructor { |hsh| hsh.deep_symbolize_keys }

ConfigConsumer =

Types.Constructor(Config::Consumer)

ConfigDeserializer =

Types.Constructor(Config::Deserializer)

ConfigTopic =

Types.Constructor(Config::Topic)