Skip to content

Commit e1dd4e1

Browse files
authored
feat: use self-signed JWTs with ServiceAccountCredentials in ConnectorCredentialsProvider (#433)
1 parent 2e4873f commit e1dd4e1

1 file changed

Lines changed: 2 additions & 0 deletions

File tree

src/main/java/com/google/pubsub/kafka/common/ConnectorCredentialsProvider.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -71,6 +71,7 @@ public static ConnectorCredentialsProvider getServiceAccountFromFile(String cred
7171
return new ConnectorCredentialsProvider(
7272
() ->
7373
ServiceAccountCredentials.fromStream(new FileInputStream(credentialsSAPath))
74+
.createWithUseJwtAccessWithScope(true)
7475
.createScoped(GCP_SCOPE));
7576
}
7677

@@ -79,6 +80,7 @@ public static ConnectorCredentialsProvider getServiceAccountFromJson(String cred
7980
() ->
8081
ServiceAccountCredentials.fromStream(
8182
new ByteArrayInputStream(credentialsSAJson.getBytes()))
83+
.createWithUseJwtAccessWithScope(true)
8284
.createScoped(GCP_SCOPE));
8385
}
8486

0 commit comments

Comments
 (0)