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

feat(kafka): SASL authentication and additional configuration #385

Merged
merged 1 commit into from
Nov 30, 2022

Conversation

Lowaiz
Copy link
Contributor

@Lowaiz Lowaiz commented Nov 28, 2022

Co-authored-by: Luke Young lyoung@confluent.io
Co-authored-by: Lyonel Martinez lyonel.martinez@numberly.com

Signed-off-by: Lyonel Martinez lyonel.martinez@numberly.com

As the PR looks a bit stalled: Applying changes request from #381

What type of PR is this?
/kind feature
/area outputs

What this PR does / why we need it:
This PR adds some new features to the Kafka output:

SASL authentication including PLAIN, SCRAM_SHA256 and SCRAM_SHA512
Message compression as either GZIP, SNAPPY, LZ4, ZSTD or NONE (default)
Partition balancing as crc32, murmer2, least_bytes and round_robin (default)
Async message production via a completion callback
Other additional configuration knobs like required_acks and client.id

All of these features already existed in the latest version of the upstream Kafka library that was already in use, this is mostly just boilerplate to wire up the configuration.

Which issue(s) this PR fixes:
Fixes #273 (not including MTLS support)

outputs/kafka.go Outdated Show resolved Hide resolved
Co-authored-by: Luke Young <lyoung@confluent.io>
Co-authored-by: Lyonel Martinez <lyonel.martinez@numberly.com>
Signed-off-by: Lyonel Martinez <lyonel.martinez@numberly.com>
@Lowaiz
Copy link
Contributor Author

Lowaiz commented Nov 30, 2022

@Issif I did the Co-authored tag

@poiana poiana added the lgtm label Nov 30, 2022
@poiana
Copy link

poiana commented Nov 30, 2022

[APPROVALNOTIFIER] This PR is APPROVED

This pull-request has been approved by: Issif, Lowaiz

The full list of commands accepted by this bot can be found here.

The pull request process is described here

Needs approval from an approver in each of these files:

Approvers can indicate their approval by writing /approve in a comment
Approvers can cancel approval by writing /approve cancel in a comment

@poiana
Copy link

poiana commented Nov 30, 2022

LGTM label has been added.

Git tree hash: 2fb861a46865a421fcdeaf9124eea8e996242fe4

@poiana poiana merged commit e802412 into falcosecurity:master Nov 30, 2022
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
Status: Done
Development

Successfully merging this pull request may close these issues.

Kafka authentication/encryption
3 participants