Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

out_kafka: add support for dynamic/static headers #1341

Open
wants to merge 1 commit into
base: master
Choose a base branch
from

Conversation

DIFRIN
Copy link

@DIFRIN DIFRIN commented Mar 15, 2024

Add support for dynamic or static header for the kafka output plugin

Example:
'docker run --rm --network kafka_default -e value_test='${text}' -it fluent/fluent-bit-local:latest -i dummy -p dummy='{"text": "hello world"}' -p samples=1 -o kafka -p brokers=kafka:9092 -p topics=test_fluentbit -p header="key2 <text>" -vvv'

Gives
kafka-console-consumer --topic test_fluentbit --bootstrap-server kafka:9092 --property print.headers=true
key2:hello world {"@timestamp":1710505560.027627,"text":"hello world"}

@lecaros
Copy link
Contributor

lecaros commented Apr 17, 2024

Hi @DIFRIN,
please sort the DCO issue.

@lecaros lecaros added waiting-for-user Waiting for user/contributors feedback or requested changes dco DCO failing waiting-on-code-merge labels Apr 17, 2024
@DIFRIN DIFRIN requested review from a team as code owners May 29, 2024 19:25
@DIFRIN
Copy link
Author

DIFRIN commented May 29, 2024

Hi @lecaros

DCO ok. Can you please review my merge request at fluent-bit repo

@lecaros lecaros added conflict Waiting on conflict to be resolved by contributor and removed dco DCO failing labels Aug 16, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
conflict Waiting on conflict to be resolved by contributor waiting-for-user Waiting for user/contributors feedback or requested changes waiting-on-code-merge
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants