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

ticdc: add kafka oauth configurations #13849

Merged
merged 5 commits into from
Jul 3, 2023
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
16 changes: 16 additions & 0 deletions ticdc/ticdc-changefeed-config.md
Original file line number Diff line number Diff line change
Expand Up @@ -198,4 +198,20 @@ use-file-backend = false
integrity-check-level = "none"
# Specifies the log level of the Changefeed when the checksum validation for single-row data fails. The default value is "warn". Value options are "warn" and "error".
corruption-handle-level = "warn"
hi-rustin marked this conversation as resolved.
Show resolved Hide resolved
# The following configuration only takes effect when the downstream is Kafka.
[sink.kafka-config]
# Kafka SASL authentication mechanism. The default value of this parameter is null, indicating that SASL authentication is not used.
sasl-mechanism = "OAUTHBEARER"
# The client-id in the Kafka SASL OAUTHBEARER authentication mechanism. The default value is empty. This parameter is required when using this authentication mechanism.
sasl-oauth-client-id = "producer-kafka"
# The client-secret in the Kafka SASL OAUTHBEARER authentication mechanism. The default value is empty. This parameter is required when using this authentication mechanism.
sasl-oauth-client-secret = "cHJvZHVjZXIta2Fma2E="
# The token URL in the Kafka SASL OAUTHBEARER authentication mechanism to obtain the token. The default value is empty. This parameter is required when using this authentication mechanism.
sasl-oauth-token-url = "http://127.0.0.1:4444/oauth2/token"
# The scope in the Kafka SASL OAUTHBEARER authentication mechanism. The default value is empty. This parameter is optional when using this authentication mechanism.
sasl-oauth-scopes = ["producer.kafka", "consumer.kafka"]
# The grant type in the Kafka SASL OAUTHBEARER authentication mechanism. The default value is `client_credentials`. This parameter is optional when using this authentication mechanism.
sasl-oauth-grant-type = "client_credentials"
# The audience in the Kafka SASL OAUTHBEARER authentication mechanism. The default value is empty. This parameter is optional when using this authentication mechanism.
sasl-oauth-audience = "kafka"
hi-rustin marked this conversation as resolved.
Show resolved Hide resolved
```