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

Support SASL_SSL kafka authentication for OpenLineage pipeline connector #16582

Closed
MChamberlin opened this issue Jun 9, 2024 · 0 comments · Fixed by #16597
Closed

Support SASL_SSL kafka authentication for OpenLineage pipeline connector #16582

MChamberlin opened this issue Jun 9, 2024 · 0 comments · Fixed by #16597
Assignees
Labels
enhancement New feature or request

Comments

@MChamberlin
Copy link
Contributor

FEATURE REQUEST: The OpenLineage pipeline connector should support consuming from topics on a Confluent Cloud kafka cluster using their native authentication methods.

The preferred authentication mechanism for a Confluent Cloud kafka cluster is SASL_SSL using an API key and secret.

To support this, the OpenLineage connector and kafka client configuration should handle the following fields/values:

{
        'security.protocol': 'SASL_SSL',
        'sasl.mechanism': 'PLAIN',
        'sasl.username': '...',
        'sasl.password': '...'
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
enhancement New feature or request
Projects
None yet
Development

Successfully merging a pull request may close this issue.

2 participants