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] Generate_ID feature request #2139

Closed
simonasr opened this issue Apr 29, 2020 · 3 comments
Closed

[out_kafka] Generate_ID feature request #2139

simonasr opened this issue Apr 29, 2020 · 3 comments
Labels

Comments

@simonasr
Copy link

Is your feature request related to a problem? Please describe.
We want to prevent log duplicates when re-consumed from Kafka backlog (in case we need to 'replay' logs from Kafka to fix some data loss caused by fluentd or ES problem)
Our pipeline:

+-----------+        +-----------+        +-----------+        +-----------+
| Fluentbit |  ----> |   KAFKA   |  ----> |   Fluend  |  ----> |   ES      |
+-----------+        +-----------+        +-----------+        +-----------+

Describe the solution you'd like
out_kafka plugin could generate and add key with random ID to the record.
This key later would be used as _id in ElasticSearch.

Describe alternatives you've considered
Currently we are using Fluentd plugin genhashvalue which calculates hash for the log, but this is not very elegant solution for the problem.
It would be great if Fluentbit adds random ID to the record

Additional context
🙏

@github-actions
Copy link
Contributor

This issue is stale because it has been open 30 days with no activity. Remove stale label or comment or this will be closed in 5 days.

@github-actions github-actions bot added the Stale label May 22, 2021
@github-actions
Copy link
Contributor

This issue was closed because it has been stalled for 5 days with no activity.

@vikasmishra17
Copy link

Hi,

we have followed the same configuration as shown in #2268

But in the output the hash id is not generating

My output configuration

[OUTPUT]
name kafka
match *
brokers X.XX.XX.XX:9092,XX.XX.XX.:9092,XX.XX.XX:9092
topics syslogs-id
Hash On
Hash_Key _myid
retry_Limit false

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Projects
None yet
Development

No branches or pull requests

2 participants