kafka.yaml

# This file was auto generated by benthos_config_gen.
http:
  address: 0.0.0.0:4195
  read_timeout: 5s
  root_path: /benthos
  debug_endpoints: false
input:
  type: kafka
  kafka:
    addresses:
    - localhost:9092
    batching:
      byte_size: 0
      condition:
        type: static
        static: false
      count: 1
      period: ""
    client_id: benthos_kafka_input
    commit_period: 1s
    consumer_group: benthos_consumer_group
    fetch_buffer_cap: 256
    max_batch_count: 1
    max_processing_period: 100ms
    partition: 0
    sasl:
      enabled: false
      password: ""
      user: ""
    start_from_oldest: true
    target_version: 1.0.0
    tls:
      client_certs: []
      enabled: false
      root_cas_file: ""
      skip_cert_verify: false
    topic: benthos_stream
buffer:
  type: none
  none: {}
pipeline:
  processors: []
  threads: 1
output:
  type: kafka
  kafka:
    ack_replicas: false
    addresses:
    - localhost:9092
    backoff:
      initial_interval: 0s
      max_elapsed_time: 5s
      max_interval: 1s
    client_id: benthos_kafka_output
    compression: none
    key: ""
    max_msg_bytes: 1e+06
    max_retries: 0
    round_robin_partitions: false
    sasl:
      enabled: false
      password: ""
      user: ""
    target_version: 1.0.0
    timeout: 5s
    tls:
      client_certs: []
      enabled: false
      root_cas_file: ""
      skip_cert_verify: false
    topic: benthos_stream
resources:
  caches: {}
  conditions: {}
  processors: {}
  rate_limits: {}
logger:
  prefix: benthos
  level: INFO
  add_timestamp: true
  json_format: true
  static_fields:
    '@service': benthos
metrics:
  type: http_server
  http_server:
    prefix: benthos
tracer:
  type: none
  none: {}
shutdown_timeout: 20s