Rename groupId

bakdata · Jul 25, 2024 · 9885db6 · 9885db6
1 parent 5dd7da5
commit 9885db6
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/charts/streams-app-cleanup-job/templates/job.yaml b/charts/streams-app-cleanup-job/templates/job.yaml
@@ -106,7 +106,7 @@ spec:
               value: "{{- range $key, $value := .Values.kafka.extraInputPatterns }}{{ $key }}={{ $value }},{{- end }}"
             {{- end }}
             {{- if hasKey .Values.kafka "groupId" }}
-            - name: "{{ .Values.configurationEnvPrefix }}_APPLICATION_ID"
+            - name: "{{ .Values.configurationEnvPrefix }}_GROUP_ID"
               value: {{ .Values.kafka.groupId | quote }}
             {{- end }}
             {{- range $key, $value := .Values.secrets }}

diff --git a/charts/streams-app/templates/deployment.yaml b/charts/streams-app/templates/deployment.yaml
@@ -153,7 +153,7 @@ spec:
               value: "{{- range $key, $value := .Values.kafka.extraInputPatterns }}{{ $key }}={{ $value }},{{- end }}"
           {{- end }}
           {{- if hasKey .Values.kafka "groupId" }}
-            - name: "{{ .Values.configurationEnvPrefix }}_APPLICATION_ID"
+            - name: "{{ .Values.configurationEnvPrefix }}_GROUP_ID"
               value: {{ .Values.kafka.groupId | quote }}
           {{- end }}
           {{- range $key, $value := .Values.secrets }}

diff --git a/streams-bootstrap-core/src/main/java/com/bakdata/kafka/StreamsCleanUpRunner.java b/streams-bootstrap-core/src/main/java/com/bakdata/kafka/StreamsCleanUpRunner.java
@@ -101,7 +101,7 @@ public static void runResetter(final Collection<String> inputTopics, final Colle
         final String appId = streamsAppConfig.getAppId();
         final File tempFile = createTemporaryPropertiesFile(appId, streamsAppConfig.getKafkaProperties());
         final ImmutableList.Builder<String> argList = ImmutableList.<String>builder()
-                .add("--group-id", appId)
+                .add("--application-id", appId)
                 .add("--bootstrap-server", String.join(",", streamsAppConfig.getBoostrapServers()))
                 .add("--config-file", tempFile.toString());
         final Collection<String> existingInputTopics = filterExistingTopics(inputTopics, allTopics);