-
Notifications
You must be signed in to change notification settings - Fork 477
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
Add an Apache Kafka output module #162
Conversation
This provides a module to produce logs on an Apache Kafka distributed queue. The configuration allows choosing a fixed, random or dynamic partition key for payloads. Message payloads are generated with a template. The configuration also allows setting arbitrary metadata and topic metadata.
Here's a simple configuration excerpt:
|
A few questions, while I'm reviewing:
|
As discussed on IRC, a better target for this module is the syslog-ng incubator, thanks for the review! |
Signed-off-by: Attila Szakacs <[email protected]>
Signed-off-by: Attila Szakacs <[email protected]>
macros: extract type information from MESSAGE, PROGRAM and HOST
This provides a module to produce logs on an Apache Kafka
distributed queue.
The configuration allows choosing a fixed, random or dynamic
partition key for payloads. Message payloads are generated
with a template. The configuration also allows setting
arbitrary metadata and topic metadata.