input {
  kafka {
    bootstrap_servers => "" #configurable
    group_id => "" #configurable
    auto_offset_reset => "" #configurable
    security_protocol => "SASL_SSL"
    sasl_mechanism => "SCRAM-SHA-512"
    sasl_jaas_config => "org.apache.kafka.common.security.scram.ScramLoginModule required username='' password='';"
    ssl_endpoint_identification_algorithm => ""
    topics => [""] #configurable
  }
}