We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 31b828f commit be42048Copy full SHA for be42048
automq-shell/src/main/java/com/automq/shell/commands/cluster/Deploy.java
@@ -110,9 +110,11 @@ private static void bucketReadinessCheck(ClusterTopology topo) {
110
String globalAccessKey = null;
111
String globalSecretKey = null;
112
for (Env env : topo.getGlobal().getEnvs()) {
113
- if ("KAFKA_S3_ACCESS_KEY".equals(env.getName())) {
+ if ("KAFKA_S3_ACCESS_KEY".equals(env.getName()) ||
114
+ "AWS_ACCESS_KEY_ID".equals(env.getName())) {
115
globalAccessKey = env.getValue();
- } 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())) {
118
globalSecretKey = env.getValue();
119
}
120
0 commit comments