default: &default
  client_id: 'some-name'
  max_wait_time: 1
  shutdown_timeout: 60
  concurrency: 4
  pause_timeout: 1
  pause_max_timeout: 30
  pause_with_exponential_backoff: true
## available strategies: range, roundrobin, cooperative-sticky
#  partition_assignment_strategy: "range,roundrobin"
  auth:
    kind: plaintext
  kafka:
    servers: "kafka:9092"
    heartbeat_timeout: 5
    session_timeout: 30
    reconnect_timeout: 3
    connect_timeout: 5
    socket_timeout: 30
    kafka_options:
      allow.auto.create.topics: true
  consumer_groups:
#    group_ref_id_1:
#      name: cg_with_single_topic
#      topics:
#        - name: topic_with_inbox_items
#          consumer:
#            klass: "Sbmt::KafkaConsumer::InboxConsumer"
#            init_attrs:
#              name: "test_items"
#              inbox_item: "TestInboxItem"
#          deserializer:
#            klass: "Sbmt::KafkaConsumer::Serialization::NullDeserializer"
#    group_ref_id_2:
#      name: cg_with_multiple_topics
#      topics:
#        - name: topic_with_json_data
#          consumer:
#            klass: "Sbmt::KafkaConsumer::SimpleLoggingConsumer"
#          deserializer:
#            klass: "Sbmt::KafkaConsumer::Serialization::JsonDeserializer"
#        - name: topic_with_protobuf_data
#          consumer:
#            klass: "Sbmt::KafkaConsumer::SimpleLoggingConsumer"
#          deserializer:
#            klass: "Sbmt::KafkaConsumer::Serialization::ProtobufDeserializer"
#            init_attrs:
#              message_decoder_klass: "Sso::UserRegistration"
#              skip_decoding_error: true
  probes:
    port: 9394

development:
  <<: *default
test:
  <<: *default
  deliver: false
staging: &staging
  <<: *default
production:
  <<: *staging