From 9244e3ce9a5248339eaf4fcbde8e71ac8aa7d08f Mon Sep 17 00:00:00 2001 From: Philipp Schirmer Date: Mon, 10 Aug 2026 12:55:04 +0200 Subject: [PATCH 1/5] Mount state to non-temporary directory --- charts/consumer-app/README.md | 23 ++++++++------- charts/consumer-app/templates/deployment.yaml | 4 ++- charts/consumer-app/values.yaml | 1 + charts/consumerproducer-app/README.md | 29 ++++++++++--------- .../templates/deployment.yaml | 4 ++- charts/consumerproducer-app/values.yaml | 1 + charts/streams-app/README.md | 29 ++++++++++--------- charts/streams-app/templates/deployment.yaml | 4 ++- charts/streams-app/values.yaml | 1 + 9 files changed, 54 insertions(+), 42 deletions(-) diff --git a/charts/consumer-app/README.md b/charts/consumer-app/README.md index 0942dfc2c..2d6a40e1e 100644 --- a/charts/consumer-app/README.md +++ b/charts/consumer-app/README.md @@ -52,17 +52,18 @@ Alternatively, a YAML file that specifies the values for the parameters can be p ### Kafka -| Parameter | Description | Default | -|------------------------------|----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|---------| -| `kafka.bootstrapServers` | Comma separated list of Kafka bootstrap servers to connect to. | | -| `kafka.schemaRegistryUrl` | URL of Schema Registry to connect to. | `null` | -| `kafka.staticMembership` | Whether to use [Kafka Static Group Membership](https://cwiki.apache.org/confluence/display/KAFKA/KIP-345%3A+Introduce+static+membership+protocol+to+reduce+consumer+rebalances). | `false` | -| `kafka.config` | Configurations for your [Kafka Consumer app](https://kafka.apache.org/documentation/#consumerconfigs). | `{}` | -| `kafka.inputTopics` | List of input topics for your consumer application. | `[]` | -| `kafka.labeledInputTopics` | Map of additional labeled input topics if you need to specify multiple topics with different message types. | `{}` | -| `kafka.inputPattern` | Input pattern of topics for your consumer application. | | -| `kafka.labeledInputPatterns` | Map of additional labeled input patterns if you need to specify multiple topics with different message types. | `{}` | -| `kafka.groupId` | Unique group ID for Kafka Consumer. Required for auto-scaling | | +| Parameter | Description | Default | +|------------------------------|----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|-------------------------| +| `kafka.bootstrapServers` | Comma separated list of Kafka bootstrap servers to connect to. | | +| `kafka.schemaRegistryUrl` | URL of Schema Registry to connect to. | `null` | +| `kafka.staticMembership` | Whether to use [Kafka Static Group Membership](https://cwiki.apache.org/confluence/display/KAFKA/KIP-345%3A+Introduce+static+membership+protocol+to+reduce+consumer+rebalances). | `false` | +| `kafka.stateDir` | Directory for app state. | `/state/kafka-consumer` | +| `kafka.config` | Configurations for your [Kafka Consumer app](https://kafka.apache.org/documentation/#consumerconfigs). | `{}` | +| `kafka.inputTopics` | List of input topics for your consumer application. | `[]` | +| `kafka.labeledInputTopics` | Map of additional labeled input topics if you need to specify multiple topics with different message types. | `{}` | +| `kafka.inputPattern` | Input pattern of topics for your consumer application. | | +| `kafka.labeledInputPatterns` | Map of additional labeled input patterns if you need to specify multiple topics with different message types. | `{}` | +| `kafka.groupId` | Unique group ID for Kafka Consumer. Required for auto-scaling | | ### Other diff --git a/charts/consumer-app/templates/deployment.yaml b/charts/consumer-app/templates/deployment.yaml index d93d272c3..c8168ced4 100644 --- a/charts/consumer-app/templates/deployment.yaml +++ b/charts/consumer-app/templates/deployment.yaml @@ -15,6 +15,8 @@ spec: env: {{- include "kafka-app.common-env" . | nindent 12 }} {{- include "kafka-app.group-instance-id-env" . | indent 12 }} + - name: KAFKA_STATE_DIR + value: {{ .Values.kafka.stateDir }} {{- include "kafka-app.input-env" . | indent 12 }} {{- include "kafka-app.group-id-env" . | indent 12 }} - name: JAVA_TOOL_OPTIONS @@ -25,7 +27,7 @@ spec: {{- include "kafka-app.volume-mounts" . | indent 12 }} {{- if and .Values.persistence.enabled .Values.statefulSet }} - name: datadir - mountPath: /tmp/kafka-consumer + mountPath: {{ .Values.kafka.stateDir }} {{- end }} {{- end }} {{- if or (.Values.jmx.enabled) (.Values.ports) }} diff --git a/charts/consumer-app/values.yaml b/charts/consumer-app/values.yaml index ed1c1b039..642da3b34 100644 --- a/charts/consumer-app/values.yaml +++ b/charts/consumer-app/values.yaml @@ -28,6 +28,7 @@ kafka: # bootstrapServers: "test:9092" # schemaRegistryUrl: "url:1234" staticMembership: false + stateDir: /state/kafka-consumer config: {} # max.poll.records: 500 # Note that YAML may convert large integers to scientific notation. Use Strings to avoid this. diff --git a/charts/consumerproducer-app/README.md b/charts/consumerproducer-app/README.md index 35c071712..09158b4f4 100644 --- a/charts/consumerproducer-app/README.md +++ b/charts/consumerproducer-app/README.md @@ -52,20 +52,21 @@ Alternatively, a YAML file that specifies the values for the parameters can be p ### Kafka -| Parameter | Description | Default | -|------------------------------|----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|---------| -| `kafka.bootstrapServers` | Comma separated list of Kafka bootstrap servers to connect to. | | -| `kafka.schemaRegistryUrl` | URL of Schema Registry to connect to. | `null` | -| `kafka.staticMembership` | Whether to use [Kafka Static Group Membership](https://cwiki.apache.org/confluence/display/KAFKA/KIP-345%3A+Introduce+static+membership+protocol+to+reduce+consumer+rebalances). | `false` | -| `kafka.config` | Configurations for your Kafka [Consumer](https://kafka.apache.org/documentation/#consumerconfigs) and [Producer](https://kafka.apache.org/documentation/#producerconfigs) app. | `{}` | -| `kafka.inputTopics` | List of input topics for your ConsumerProducer application. | `[]` | -| `kafka.labeledInputTopics` | Map of additional labeled input topics if you need to specify multiple topics with different message types. | `{}` | -| `kafka.inputPattern` | Input pattern of topics for your ConsumerProducer application. | | -| `kafka.labeledInputPatterns` | Map of additional labeled input patterns if you need to specify multiple topics with different message types. | `{}` | -| `kafka.outputTopic` | Output topic for your ConsumerProducer application. | | -| `kafka.labeledOutputTopics` | Map of additional labeled output topics if you need to specify multiple topics with different message types. | `{}` | -| `kafka.errorTopic` | Error topic for your ConsumerProducer application. | | -| `kafka.groupId` | Unique group ID for Kafka ConsumerProducer. Required for auto-scaling | | +| Parameter | Description | Default | +|------------------------------|----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|----------------------------------| +| `kafka.bootstrapServers` | Comma separated list of Kafka bootstrap servers to connect to. | | +| `kafka.schemaRegistryUrl` | URL of Schema Registry to connect to. | `null` | +| `kafka.staticMembership` | Whether to use [Kafka Static Group Membership](https://cwiki.apache.org/confluence/display/KAFKA/KIP-345%3A+Introduce+static+membership+protocol+to+reduce+consumer+rebalances). | `false` | +| `kafka.stateDir` | Directory for app state. | `/state/kafka-consumer-producer` | +| `kafka.config` | Configurations for your Kafka [Consumer](https://kafka.apache.org/documentation/#consumerconfigs) and [Producer](https://kafka.apache.org/documentation/#producerconfigs) app. | `{}` | +| `kafka.inputTopics` | List of input topics for your ConsumerProducer application. | `[]` | +| `kafka.labeledInputTopics` | Map of additional labeled input topics if you need to specify multiple topics with different message types. | `{}` | +| `kafka.inputPattern` | Input pattern of topics for your ConsumerProducer application. | | +| `kafka.labeledInputPatterns` | Map of additional labeled input patterns if you need to specify multiple topics with different message types. | `{}` | +| `kafka.outputTopic` | Output topic for your ConsumerProducer application. | | +| `kafka.labeledOutputTopics` | Map of additional labeled output topics if you need to specify multiple topics with different message types. | `{}` | +| `kafka.errorTopic` | Error topic for your ConsumerProducer application. | | +| `kafka.groupId` | Unique group ID for Kafka ConsumerProducer. Required for auto-scaling | | ### Other diff --git a/charts/consumerproducer-app/templates/deployment.yaml b/charts/consumerproducer-app/templates/deployment.yaml index 88fa4bcaf..812f16e7a 100644 --- a/charts/consumerproducer-app/templates/deployment.yaml +++ b/charts/consumerproducer-app/templates/deployment.yaml @@ -25,6 +25,8 @@ spec: {{- end }} {{- end }} {{- include "kafka-app.group-instance-id-env" . | indent 12 }} + - name: KAFKA_STATE_DIR + value: {{ .Values.kafka.stateDir }} {{- include "kafka-app.input-env" . | indent 12 }} {{- include "kafka-app.output-env" . | indent 12 }} {{- include "kafka-app.error-env" . | indent 12 }} @@ -37,7 +39,7 @@ spec: {{- include "kafka-app.volume-mounts" . | indent 12 }} {{- if and .Values.persistence.enabled .Values.statefulSet }} - name: datadir - mountPath: /tmp/kafka-streams + mountPath: {{ .Values.kafka.stateDir }} {{- end }} {{- end }} {{- if or (.Values.jmx.enabled) (.Values.ports) }} diff --git a/charts/consumerproducer-app/values.yaml b/charts/consumerproducer-app/values.yaml index ab7b59a56..7370dc33c 100644 --- a/charts/consumerproducer-app/values.yaml +++ b/charts/consumerproducer-app/values.yaml @@ -28,6 +28,7 @@ kafka: # bootstrapServers: "test:9092" # schemaRegistryUrl: "url:1234" staticMembership: false + stateDir: /state/kafka-consumer-producer config: {} # max.poll.records: 500 # Note that YAML may convert large integers to scientific notation. Use Strings to avoid this. diff --git a/charts/streams-app/README.md b/charts/streams-app/README.md index 93e9fed62..8f67872c6 100644 --- a/charts/streams-app/README.md +++ b/charts/streams-app/README.md @@ -52,20 +52,21 @@ Alternatively, a YAML file that specifies the values for the parameters can be p ### Kafka -| Parameter | Description | Default | -|------------------------------|----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|---------| -| `kafka.bootstrapServers` | Comma separated list of Kafka bootstrap servers to connect to. | | -| `kafka.schemaRegistryUrl` | URL of Schema Registry to connect to. | `null` | -| `kafka.staticMembership` | Whether to use [Kafka Static Group Membership](https://cwiki.apache.org/confluence/display/KAFKA/KIP-345%3A+Introduce+static+membership+protocol+to+reduce+consumer+rebalances). | `false` | -| `kafka.config` | Configurations for your [Kafka Streams app](https://kafka.apache.org/documentation/#streamsconfigs). | `{}` | -| `kafka.inputTopics` | List of input topics for your streams application. | `[]` | -| `kafka.labeledInputTopics` | Map of additional labeled input topics if you need to specify multiple topics with different message types. | `{}` | -| `kafka.inputPattern` | Input pattern of topics for your streams application. | | -| `kafka.labeledInputPatterns` | Map of additional labeled input patterns if you need to specify multiple topics with different message types. | `{}` | -| `kafka.outputTopic` | Output topic for your streams application. | | -| `kafka.labeledOutputTopics` | Map of additional labeled output topics if you need to specify multiple topics with different message types. | `{}` | -| `kafka.errorTopic` | Error topic for your streams application. | | -| `kafka.applicationId` | Unique application ID for Kafka Streams. Required for auto-scaling | | +| Parameter | Description | Default | +|------------------------------|----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|------------------------| +| `kafka.bootstrapServers` | Comma separated list of Kafka bootstrap servers to connect to. | | +| `kafka.schemaRegistryUrl` | URL of Schema Registry to connect to. | `null` | +| `kafka.staticMembership` | Whether to use [Kafka Static Group Membership](https://cwiki.apache.org/confluence/display/KAFKA/KIP-345%3A+Introduce+static+membership+protocol+to+reduce+consumer+rebalances). | `false` | +| `kafka.stateDir` | Directory for Kafka Streams state. | `/state/kafka-streams` | +| `kafka.config` | Configurations for your [Kafka Streams app](https://kafka.apache.org/documentation/#streamsconfigs). | `{}` | +| `kafka.inputTopics` | List of input topics for your streams application. | `[]` | +| `kafka.labeledInputTopics` | Map of additional labeled input topics if you need to specify multiple topics with different message types. | `{}` | +| `kafka.inputPattern` | Input pattern of topics for your streams application. | | +| `kafka.labeledInputPatterns` | Map of additional labeled input patterns if you need to specify multiple topics with different message types. | `{}` | +| `kafka.outputTopic` | Output topic for your streams application. | | +| `kafka.labeledOutputTopics` | Map of additional labeled output topics if you need to specify multiple topics with different message types. | `{}` | +| `kafka.errorTopic` | Error topic for your streams application. | | +| `kafka.applicationId` | Unique application ID for Kafka Streams. Required for auto-scaling | | ### Other diff --git a/charts/streams-app/templates/deployment.yaml b/charts/streams-app/templates/deployment.yaml index 6fd0fd33f..bae36ada7 100644 --- a/charts/streams-app/templates/deployment.yaml +++ b/charts/streams-app/templates/deployment.yaml @@ -25,6 +25,8 @@ spec: {{- end }} {{- end }} {{- include "kafka-app.group-instance-id-env" . | indent 12 }} + - name: KAFKA_STATE_DIR + value: {{ .Values.kafka.stateDir }} {{- include "kafka-app.input-env" . | indent 12 }} {{- include "kafka-app.output-env" . | indent 12 }} {{- include "kafka-app.error-env" . | indent 12 }} @@ -37,7 +39,7 @@ spec: {{- include "kafka-app.volume-mounts" . | indent 12 }} {{- if and .Values.persistence.enabled .Values.statefulSet }} - name: datadir - mountPath: /tmp/kafka-streams + mountPath: {{ .Values.kafka.stateDir }} {{- end }} {{- end }} {{- if or (.Values.jmx.enabled) (.Values.ports) }} diff --git a/charts/streams-app/values.yaml b/charts/streams-app/values.yaml index 33ba98e05..59f461065 100644 --- a/charts/streams-app/values.yaml +++ b/charts/streams-app/values.yaml @@ -28,6 +28,7 @@ kafka: # bootstrapServers: "test:9092" # schemaRegistryUrl: "url:1234" staticMembership: false + stateDir: /state/kafka-streams config: {} # max.poll.records: 500 # Note that YAML may convert large integers to scientific notation. Use Strings to avoid this. From 96cff06e934c5399a442dca3496cd69629007187 Mon Sep 17 00:00:00 2001 From: Philipp Schirmer Date: Mon, 10 Aug 2026 13:09:12 +0200 Subject: [PATCH 2/5] Quote --- charts/consumer-app/templates/deployment.yaml | 4 ++-- charts/consumerproducer-app/templates/deployment.yaml | 4 ++-- charts/streams-app/templates/deployment.yaml | 4 ++-- 3 files changed, 6 insertions(+), 6 deletions(-) diff --git a/charts/consumer-app/templates/deployment.yaml b/charts/consumer-app/templates/deployment.yaml index c8168ced4..060febbc3 100644 --- a/charts/consumer-app/templates/deployment.yaml +++ b/charts/consumer-app/templates/deployment.yaml @@ -16,7 +16,7 @@ spec: {{- include "kafka-app.common-env" . | nindent 12 }} {{- include "kafka-app.group-instance-id-env" . | indent 12 }} - name: KAFKA_STATE_DIR - value: {{ .Values.kafka.stateDir }} + value: {{ .Values.kafka.stateDir | quote }} {{- include "kafka-app.input-env" . | indent 12 }} {{- include "kafka-app.group-id-env" . | indent 12 }} - name: JAVA_TOOL_OPTIONS @@ -27,7 +27,7 @@ spec: {{- include "kafka-app.volume-mounts" . | indent 12 }} {{- if and .Values.persistence.enabled .Values.statefulSet }} - name: datadir - mountPath: {{ .Values.kafka.stateDir }} + mountPath: {{ .Values.kafka.stateDir | quote }} {{- end }} {{- end }} {{- if or (.Values.jmx.enabled) (.Values.ports) }} diff --git a/charts/consumerproducer-app/templates/deployment.yaml b/charts/consumerproducer-app/templates/deployment.yaml index 812f16e7a..4d62f3b2b 100644 --- a/charts/consumerproducer-app/templates/deployment.yaml +++ b/charts/consumerproducer-app/templates/deployment.yaml @@ -26,7 +26,7 @@ spec: {{- end }} {{- include "kafka-app.group-instance-id-env" . | indent 12 }} - name: KAFKA_STATE_DIR - value: {{ .Values.kafka.stateDir }} + value: {{ .Values.kafka.stateDir | quote }} {{- include "kafka-app.input-env" . | indent 12 }} {{- include "kafka-app.output-env" . | indent 12 }} {{- include "kafka-app.error-env" . | indent 12 }} @@ -39,7 +39,7 @@ spec: {{- include "kafka-app.volume-mounts" . | indent 12 }} {{- if and .Values.persistence.enabled .Values.statefulSet }} - name: datadir - mountPath: {{ .Values.kafka.stateDir }} + mountPath: {{ .Values.kafka.stateDir | quote }} {{- end }} {{- end }} {{- if or (.Values.jmx.enabled) (.Values.ports) }} diff --git a/charts/streams-app/templates/deployment.yaml b/charts/streams-app/templates/deployment.yaml index bae36ada7..1705f710f 100644 --- a/charts/streams-app/templates/deployment.yaml +++ b/charts/streams-app/templates/deployment.yaml @@ -26,7 +26,7 @@ spec: {{- end }} {{- include "kafka-app.group-instance-id-env" . | indent 12 }} - name: KAFKA_STATE_DIR - value: {{ .Values.kafka.stateDir }} + value: {{ .Values.kafka.stateDir | quote }} {{- include "kafka-app.input-env" . | indent 12 }} {{- include "kafka-app.output-env" . | indent 12 }} {{- include "kafka-app.error-env" . | indent 12 }} @@ -39,7 +39,7 @@ spec: {{- include "kafka-app.volume-mounts" . | indent 12 }} {{- if and .Values.persistence.enabled .Values.statefulSet }} - name: datadir - mountPath: {{ .Values.kafka.stateDir }} + mountPath: {{ .Values.kafka.stateDir | quote }} {{- end }} {{- end }} {{- if or (.Values.jmx.enabled) (.Values.ports) }} From 6fa8ada0a56dcfde126f3fe0bef117f45e878836 Mon Sep 17 00:00:00 2001 From: Philipp Schirmer Date: Mon, 10 Aug 2026 13:19:43 +0200 Subject: [PATCH 3/5] Only set when persistence is enabled --- charts/consumer-app/templates/deployment.yaml | 2 ++ charts/consumerproducer-app/templates/deployment.yaml | 2 ++ charts/streams-app/templates/deployment.yaml | 2 ++ 3 files changed, 6 insertions(+) diff --git a/charts/consumer-app/templates/deployment.yaml b/charts/consumer-app/templates/deployment.yaml index 060febbc3..6f382d3c8 100644 --- a/charts/consumer-app/templates/deployment.yaml +++ b/charts/consumer-app/templates/deployment.yaml @@ -15,8 +15,10 @@ spec: env: {{- include "kafka-app.common-env" . | nindent 12 }} {{- include "kafka-app.group-instance-id-env" . | indent 12 }} + {{- if and .Values.persistence.enabled .Values.statefulSet }} - name: KAFKA_STATE_DIR value: {{ .Values.kafka.stateDir | quote }} + {{- end }} {{- include "kafka-app.input-env" . | indent 12 }} {{- include "kafka-app.group-id-env" . | indent 12 }} - name: JAVA_TOOL_OPTIONS diff --git a/charts/consumerproducer-app/templates/deployment.yaml b/charts/consumerproducer-app/templates/deployment.yaml index 4d62f3b2b..ac17f78ee 100644 --- a/charts/consumerproducer-app/templates/deployment.yaml +++ b/charts/consumerproducer-app/templates/deployment.yaml @@ -25,8 +25,10 @@ spec: {{- end }} {{- end }} {{- include "kafka-app.group-instance-id-env" . | indent 12 }} + {{- if and .Values.persistence.enabled .Values.statefulSet }} - name: KAFKA_STATE_DIR value: {{ .Values.kafka.stateDir | quote }} + {{- end }} {{- include "kafka-app.input-env" . | indent 12 }} {{- include "kafka-app.output-env" . | indent 12 }} {{- include "kafka-app.error-env" . | indent 12 }} diff --git a/charts/streams-app/templates/deployment.yaml b/charts/streams-app/templates/deployment.yaml index 1705f710f..2b05cb324 100644 --- a/charts/streams-app/templates/deployment.yaml +++ b/charts/streams-app/templates/deployment.yaml @@ -25,8 +25,10 @@ spec: {{- end }} {{- end }} {{- include "kafka-app.group-instance-id-env" . | indent 12 }} + {{- if and .Values.persistence.enabled .Values.statefulSet }} - name: KAFKA_STATE_DIR value: {{ .Values.kafka.stateDir | quote }} + {{- end }} {{- include "kafka-app.input-env" . | indent 12 }} {{- include "kafka-app.output-env" . | indent 12 }} {{- include "kafka-app.error-env" . | indent 12 }} From eadb255a9d49ea3609bc8c9480790a2b40d6c352 Mon Sep 17 00:00:00 2001 From: Philipp Schirmer Date: Mon, 10 Aug 2026 13:25:19 +0200 Subject: [PATCH 4/5] Only set when persistence is enabled --- charts/consumer-app/README.md | 2 +- charts/consumerproducer-app/README.md | 2 +- charts/streams-app/README.md | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/charts/consumer-app/README.md b/charts/consumer-app/README.md index 2d6a40e1e..481552543 100644 --- a/charts/consumer-app/README.md +++ b/charts/consumer-app/README.md @@ -57,7 +57,7 @@ Alternatively, a YAML file that specifies the values for the parameters can be p | `kafka.bootstrapServers` | Comma separated list of Kafka bootstrap servers to connect to. | | | `kafka.schemaRegistryUrl` | URL of Schema Registry to connect to. | `null` | | `kafka.staticMembership` | Whether to use [Kafka Static Group Membership](https://cwiki.apache.org/confluence/display/KAFKA/KIP-345%3A+Introduce+static+membership+protocol+to+reduce+consumer+rebalances). | `false` | -| `kafka.stateDir` | Directory for app state. | `/state/kafka-consumer` | +| `kafka.stateDir` | Directory for app state. Only configured when `persistence.enabled` and `statefulSet` are set to `true`. | `/state/kafka-consumer` | | `kafka.config` | Configurations for your [Kafka Consumer app](https://kafka.apache.org/documentation/#consumerconfigs). | `{}` | | `kafka.inputTopics` | List of input topics for your consumer application. | `[]` | | `kafka.labeledInputTopics` | Map of additional labeled input topics if you need to specify multiple topics with different message types. | `{}` | diff --git a/charts/consumerproducer-app/README.md b/charts/consumerproducer-app/README.md index 09158b4f4..588fa83ba 100644 --- a/charts/consumerproducer-app/README.md +++ b/charts/consumerproducer-app/README.md @@ -57,7 +57,7 @@ Alternatively, a YAML file that specifies the values for the parameters can be p | `kafka.bootstrapServers` | Comma separated list of Kafka bootstrap servers to connect to. | | | `kafka.schemaRegistryUrl` | URL of Schema Registry to connect to. | `null` | | `kafka.staticMembership` | Whether to use [Kafka Static Group Membership](https://cwiki.apache.org/confluence/display/KAFKA/KIP-345%3A+Introduce+static+membership+protocol+to+reduce+consumer+rebalances). | `false` | -| `kafka.stateDir` | Directory for app state. | `/state/kafka-consumer-producer` | +| `kafka.stateDir` | Directory for app state. Only configured when `persistence.enabled` and `statefulSet` are set to `true`. | `/state/kafka-consumer-producer` | | `kafka.config` | Configurations for your Kafka [Consumer](https://kafka.apache.org/documentation/#consumerconfigs) and [Producer](https://kafka.apache.org/documentation/#producerconfigs) app. | `{}` | | `kafka.inputTopics` | List of input topics for your ConsumerProducer application. | `[]` | | `kafka.labeledInputTopics` | Map of additional labeled input topics if you need to specify multiple topics with different message types. | `{}` | diff --git a/charts/streams-app/README.md b/charts/streams-app/README.md index 8f67872c6..cb3e1cb5b 100644 --- a/charts/streams-app/README.md +++ b/charts/streams-app/README.md @@ -57,7 +57,7 @@ Alternatively, a YAML file that specifies the values for the parameters can be p | `kafka.bootstrapServers` | Comma separated list of Kafka bootstrap servers to connect to. | | | `kafka.schemaRegistryUrl` | URL of Schema Registry to connect to. | `null` | | `kafka.staticMembership` | Whether to use [Kafka Static Group Membership](https://cwiki.apache.org/confluence/display/KAFKA/KIP-345%3A+Introduce+static+membership+protocol+to+reduce+consumer+rebalances). | `false` | -| `kafka.stateDir` | Directory for Kafka Streams state. | `/state/kafka-streams` | +| `kafka.stateDir` | Directory for Kafka Streams state. Only configured when `persistence.enabled` and `statefulSet` are set to `true`. | `/state/kafka-streams` | | `kafka.config` | Configurations for your [Kafka Streams app](https://kafka.apache.org/documentation/#streamsconfigs). | `{}` | | `kafka.inputTopics` | List of input topics for your streams application. | `[]` | | `kafka.labeledInputTopics` | Map of additional labeled input topics if you need to specify multiple topics with different message types. | `{}` | From f6b0d48d9cb778048d6c76e635bc0318443dfd30 Mon Sep 17 00:00:00 2001 From: Philipp Schirmer Date: Mon, 10 Aug 2026 14:17:08 +0200 Subject: [PATCH 5/5] Revert condition --- charts/consumer-app/README.md | 2 +- charts/consumer-app/templates/deployment.yaml | 2 -- charts/consumerproducer-app/README.md | 2 +- charts/consumerproducer-app/templates/deployment.yaml | 2 -- charts/streams-app/README.md | 2 +- charts/streams-app/templates/deployment.yaml | 2 -- 6 files changed, 3 insertions(+), 9 deletions(-) diff --git a/charts/consumer-app/README.md b/charts/consumer-app/README.md index 481552543..2d6a40e1e 100644 --- a/charts/consumer-app/README.md +++ b/charts/consumer-app/README.md @@ -57,7 +57,7 @@ Alternatively, a YAML file that specifies the values for the parameters can be p | `kafka.bootstrapServers` | Comma separated list of Kafka bootstrap servers to connect to. | | | `kafka.schemaRegistryUrl` | URL of Schema Registry to connect to. | `null` | | `kafka.staticMembership` | Whether to use [Kafka Static Group Membership](https://cwiki.apache.org/confluence/display/KAFKA/KIP-345%3A+Introduce+static+membership+protocol+to+reduce+consumer+rebalances). | `false` | -| `kafka.stateDir` | Directory for app state. Only configured when `persistence.enabled` and `statefulSet` are set to `true`. | `/state/kafka-consumer` | +| `kafka.stateDir` | Directory for app state. | `/state/kafka-consumer` | | `kafka.config` | Configurations for your [Kafka Consumer app](https://kafka.apache.org/documentation/#consumerconfigs). | `{}` | | `kafka.inputTopics` | List of input topics for your consumer application. | `[]` | | `kafka.labeledInputTopics` | Map of additional labeled input topics if you need to specify multiple topics with different message types. | `{}` | diff --git a/charts/consumer-app/templates/deployment.yaml b/charts/consumer-app/templates/deployment.yaml index 6f382d3c8..060febbc3 100644 --- a/charts/consumer-app/templates/deployment.yaml +++ b/charts/consumer-app/templates/deployment.yaml @@ -15,10 +15,8 @@ spec: env: {{- include "kafka-app.common-env" . | nindent 12 }} {{- include "kafka-app.group-instance-id-env" . | indent 12 }} - {{- if and .Values.persistence.enabled .Values.statefulSet }} - name: KAFKA_STATE_DIR value: {{ .Values.kafka.stateDir | quote }} - {{- end }} {{- include "kafka-app.input-env" . | indent 12 }} {{- include "kafka-app.group-id-env" . | indent 12 }} - name: JAVA_TOOL_OPTIONS diff --git a/charts/consumerproducer-app/README.md b/charts/consumerproducer-app/README.md index 588fa83ba..09158b4f4 100644 --- a/charts/consumerproducer-app/README.md +++ b/charts/consumerproducer-app/README.md @@ -57,7 +57,7 @@ Alternatively, a YAML file that specifies the values for the parameters can be p | `kafka.bootstrapServers` | Comma separated list of Kafka bootstrap servers to connect to. | | | `kafka.schemaRegistryUrl` | URL of Schema Registry to connect to. | `null` | | `kafka.staticMembership` | Whether to use [Kafka Static Group Membership](https://cwiki.apache.org/confluence/display/KAFKA/KIP-345%3A+Introduce+static+membership+protocol+to+reduce+consumer+rebalances). | `false` | -| `kafka.stateDir` | Directory for app state. Only configured when `persistence.enabled` and `statefulSet` are set to `true`. | `/state/kafka-consumer-producer` | +| `kafka.stateDir` | Directory for app state. | `/state/kafka-consumer-producer` | | `kafka.config` | Configurations for your Kafka [Consumer](https://kafka.apache.org/documentation/#consumerconfigs) and [Producer](https://kafka.apache.org/documentation/#producerconfigs) app. | `{}` | | `kafka.inputTopics` | List of input topics for your ConsumerProducer application. | `[]` | | `kafka.labeledInputTopics` | Map of additional labeled input topics if you need to specify multiple topics with different message types. | `{}` | diff --git a/charts/consumerproducer-app/templates/deployment.yaml b/charts/consumerproducer-app/templates/deployment.yaml index ac17f78ee..4d62f3b2b 100644 --- a/charts/consumerproducer-app/templates/deployment.yaml +++ b/charts/consumerproducer-app/templates/deployment.yaml @@ -25,10 +25,8 @@ spec: {{- end }} {{- end }} {{- include "kafka-app.group-instance-id-env" . | indent 12 }} - {{- if and .Values.persistence.enabled .Values.statefulSet }} - name: KAFKA_STATE_DIR value: {{ .Values.kafka.stateDir | quote }} - {{- end }} {{- include "kafka-app.input-env" . | indent 12 }} {{- include "kafka-app.output-env" . | indent 12 }} {{- include "kafka-app.error-env" . | indent 12 }} diff --git a/charts/streams-app/README.md b/charts/streams-app/README.md index cb3e1cb5b..8f67872c6 100644 --- a/charts/streams-app/README.md +++ b/charts/streams-app/README.md @@ -57,7 +57,7 @@ Alternatively, a YAML file that specifies the values for the parameters can be p | `kafka.bootstrapServers` | Comma separated list of Kafka bootstrap servers to connect to. | | | `kafka.schemaRegistryUrl` | URL of Schema Registry to connect to. | `null` | | `kafka.staticMembership` | Whether to use [Kafka Static Group Membership](https://cwiki.apache.org/confluence/display/KAFKA/KIP-345%3A+Introduce+static+membership+protocol+to+reduce+consumer+rebalances). | `false` | -| `kafka.stateDir` | Directory for Kafka Streams state. Only configured when `persistence.enabled` and `statefulSet` are set to `true`. | `/state/kafka-streams` | +| `kafka.stateDir` | Directory for Kafka Streams state. | `/state/kafka-streams` | | `kafka.config` | Configurations for your [Kafka Streams app](https://kafka.apache.org/documentation/#streamsconfigs). | `{}` | | `kafka.inputTopics` | List of input topics for your streams application. | `[]` | | `kafka.labeledInputTopics` | Map of additional labeled input topics if you need to specify multiple topics with different message types. | `{}` | diff --git a/charts/streams-app/templates/deployment.yaml b/charts/streams-app/templates/deployment.yaml index 2b05cb324..1705f710f 100644 --- a/charts/streams-app/templates/deployment.yaml +++ b/charts/streams-app/templates/deployment.yaml @@ -25,10 +25,8 @@ spec: {{- end }} {{- end }} {{- include "kafka-app.group-instance-id-env" . | indent 12 }} - {{- if and .Values.persistence.enabled .Values.statefulSet }} - name: KAFKA_STATE_DIR value: {{ .Values.kafka.stateDir | quote }} - {{- end }} {{- include "kafka-app.input-env" . | indent 12 }} {{- include "kafka-app.output-env" . | indent 12 }} {{- include "kafka-app.error-env" . | indent 12 }}