It sends the event batches to kafka brokers using sarama lib.
brokers []string required
List of kafka brokers to write to.
default_topic string required
The default topic name if nothing will be found in the event field or should_use_topic_field isn't set.
use_topic_field bool default=false
If set, the plugin will use topic name from the event field.
topic_field string default=topic
Which event field to use as topic name. It works only if should_use_topic_field is set.
workers_count cfg.Expression default=gomaxprocs*4
How many workers will be instantiated to send batches.
batch_size cfg.Expression default=capacity/4
A maximum quantity of the events to pack into one batch.
batch_size_bytes cfg.Expression default=0
A minimum size of events in a batch to send. If both batch_size and batch_size_bytes are set, they will work together.
batch_flush_timeout cfg.Duration default=200ms
After this timeout the batch will be sent even if batch isn't full.
is_sasl_enabled bool default=false
If set, the plugin will use SASL authentications mechanism.
sasl_username string default=user
If set, the plugin will use SASL authentications mechanism.
sasl_password string default=password
If set, the plugin will use SASL authentications mechanism.
is_ssl_enabled bool default=false
If set, the plugin will use SSL connections method.
ssl_skip_verify bool default=false
If set, the plugin will use skip SSL verification.
pem_file string default=/file.d/certs
If SaslSslEnabled, the plugin will use path to the PEM certificate.
Generated using insane-doc