Class: Sbmt::KafkaConsumer::Config::Kafka

Inherits:
Dry::Struct
  • Object
show all
Defined in:
lib/sbmt/kafka_consumer/config/kafka.rb

Constant Summary collapse

SERVERS_REGEXP =

srv1:port1,srv2:port2,…

/^[a-z\d.\-:]+(,[a-z\d.\-:]+)*$/.freeze

Instance Method Summary collapse

Instance Method Details

#to_kafka_options ⇒ Object 



21
22
23
24
25
26
27
28
29
30
31
 
# File 'lib/sbmt/kafka_consumer/config/kafka.rb', line 21

def to_kafka_options
  # root options take precedence over kafka_options' ones
  kafka_options.merge(
    "bootstrap.servers": servers,
    "heartbeat.interval.ms": heartbeat_timeout * 1_000,
    "session.timeout.ms": session_timeout * 1_000,
    "reconnect.backoff.max.ms": reconnect_timeout * 1_000,
    "socket.connection.setup.timeout.ms": connect_timeout * 1_000,
    "socket.timeout.ms": socket_timeout * 1_000
  ).symbolize_keys
end