Skip to content

Commit

Permalink
Update src/main/java/io/strimzi/test/container/StrimziKafkaContainer.…
Browse files Browse the repository at this point in the history
…java

Co-authored-by: Marko Strukelj <marko.strukelj@gmail.com>
Signed-off-by: Maros Orsak <maros.orsak159@gmail.com>
  • Loading branch information
see-quick and mstruk authored Nov 5, 2024
1 parent 467d26f commit 65b6c16
Showing 1 changed file with 1 addition and 11 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -501,17 +501,7 @@ protected void configureOAuthBearer(Properties properties) {
properties.setProperty("principal.builder.class", "io.strimzi.kafka.oauth.server.OAuthKafkaPrincipalBuilder");

// Construct JAAS configuration for OAUTHBEARER
final String jaasConfig = String.format(
"org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required " +
"oauth.client.id=\"%s\" " +
"oauth.client.secret=\"%s\" " +
"oauth.token.endpoint.uri=\"%s\" " +
"oauth.username.claim=\"%s\";",
this.clientId,
this.clientSecret,
this.oauthUri + "/realms/" + this.realm + "/protocol/openid-connect/token",
this.usernameClaim // e.g., "preferred_username"
);
final String jaasConfig = "org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required ;";
// Define Callback Handlers for OAUTHBEARER
final String serverCallbackHandler = "io.strimzi.kafka.oauth.server.JaasServerOauthValidatorCallbackHandler";
final String clientSideCallbackHandler = "io.strimzi.kafka.oauth.client.JaasClientOauthLoginCallbackHandler";
Expand Down

0 comments on commit 65b6c16

Please sign in to comment.