Skip to content

Commit 387557b

Browse files
fix: Added support for AWS_ACCESS_KEY_ID and AWS_SECRET_ACCESS_KEY (#2748)
fix: Added support for AWS_ACCESS_KEY_ID and AWS_SECRET_ACCESS_KEY (#2747) Added support for AWS_ACCESS_KEY_ID and AWS_SECRET_ACCESS_KEY to the list of supported environment variables. Issue #2746 Co-authored-by: Saumya Pandey <[email protected]>
1 parent bd9b78e commit 387557b

File tree

1 file changed

+4
-2
lines changed
  • automq-shell/src/main/java/com/automq/shell/commands/cluster

1 file changed

+4
-2
lines changed

automq-shell/src/main/java/com/automq/shell/commands/cluster/Deploy.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -110,9 +110,11 @@ private static void bucketReadinessCheck(ClusterTopology topo) {
110110
String globalAccessKey = null;
111111
String globalSecretKey = null;
112112
for (Env env : topo.getGlobal().getEnvs()) {
113-
if ("KAFKA_S3_ACCESS_KEY".equals(env.getName())) {
113+
if ("KAFKA_S3_ACCESS_KEY".equals(env.getName()) ||
114+
"AWS_ACCESS_KEY_ID".equals(env.getName())) {
114115
globalAccessKey = env.getValue();
115-
} else if ("KAFKA_S3_SECRET_KEY".equals(env.getName())) {
116+
} else if ("KAFKA_S3_SECRET_KEY".equals(env.getName()) ||
117+
"AWS_SECRET_ACCESS_KEY".equals(env.getName())) {
116118
globalSecretKey = env.getValue();
117119
}
118120
}

0 commit comments

Comments
 (0)