Skip to content

Commit 59f5378

Browse files
committed
out_kafka: add support for dynamic/static headers
1 parent 13c922a commit 59f5378

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

pipeline/outputs/kafka.md

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@ Kafka output plugin allows to ingest your records into an [Apache Kafka](https:/
1717
| dynamic\_topic | adds unknown topics \(found in Topic\_Key\) to Topics. So in Topics only a default topic needs to be configured | Off |
1818
| queue\_full\_retries | Fluent Bit queues data into rdkafka library, if for some reason the underlying library cannot flush the records the queue might fills up blocking new addition of records. The `queue_full_retries` option set the number of local retries to enqueue the data. The default value is 10 times, the interval between each retry is 1 second. Setting the `queue_full_retries` value to `0` set's an unlimited number of retries. | 10 |
1919
| rdkafka.{property} | `{property}` can be any [librdkafka properties](https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md) | |
20+
| Header | Add a HTTP header key/value pair. Multiple headers can be. If static header than use Header key value, if the value is part of the message than use Header key <value> | |
2021

2122
> Setting `rdkafka.log.connection.close` to `false` and `rdkafka.request.required.acks` to 1 are examples of recommended settings of librdfkafka properties.
2223
@@ -45,6 +46,7 @@ In your main configuration file append the following _Input_ & _Output_ sections
4546
Match *
4647
Brokers 192.168.1.3:9092
4748
Topics test
49+
Header test test
4850
```
4951

5052
### Avro Support

0 commit comments

Comments
 (0)