Sha256: d4f9aa41dab81e7d025b1b2377bd7a822c0349e43017810cb20870828cca02d4
Contents?: true
Size: 1.72 KB
Versions: 20
Compression:
Stored size: 1.72 KB
Contents
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
Version data entries
20 entries across 20 versions & 1 rubygems