logger-kafka-event-emitter

config:

enable = true
level = "debug"
client_id = ""
flush_interval = "10s"
batch_count = 100
brokers = []
authentication_timeout = "10s"
reauthentication_threshold = "10s"
reconnect_interval = "10s"
request_timeout = "10s"

[keys]
    key1 = "key1-value"
    key2 = "key2-value"

[producer]
    metadata_max_age = "300s"
    allow_auto_topic_creation = false
    transaction_timeout = "60s"
    idempotent = false
    max_in_flight_requests = 0

[destination]
    topic = ""
    acks = "all"
    timeout = "30s"
    compression = "none"
    [destination.messages]
        key_prefix = "id_"
#        partition = 0
        [destination.messages.headers]
            header1 = "header1-value"
            header2 = "header2-value"

[ssl]
    reject_unauthorized = true
    ca = ""
    key = ""
    cert = ""
    ca_file = ""
    key_file = ""
    cert_file = ""

[auth]
    mechanism = "plain"
    username = ""
    password = ""
    authorization_identity = ""
    access_key_id = ""
    secret_access_key = ""
    session_token = ""