Skip to content

Commit 860fd5c

Browse files
committed
fix: confluent cloud service account creation
1 parent 4c6702d commit 860fd5c

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/com/devshawn/kafka/gitops/StateManager.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -127,7 +127,7 @@ public void createServiceAccounts() {
127127
}
128128

129129
private void createServiceAccount(String name, List<ServiceAccount> serviceAccounts, AtomicInteger count, boolean isUser) {
130-
if (serviceAccounts.stream().noneMatch(it -> it.getName().equals(name))) {
130+
if (serviceAccounts.stream().noneMatch(it -> it.getName().equals(isUser ? String.format("user-%s", name) : name))) {
131131
confluentCloudService.createServiceAccount(name, isUser);
132132
LogUtil.printSimpleSuccess(String.format("Successfully created service account: %s", name));
133133
count.getAndIncrement();

0 commit comments

Comments
 (0)