diff --git a/charts/producer-app-cleanup-job/templates/job.yaml b/charts/producer-app-cleanup-job/templates/job.yaml index 50a4a4ea..a6a94422 100644 --- a/charts/producer-app-cleanup-job/templates/job.yaml +++ b/charts/producer-app-cleanup-job/templates/job.yaml @@ -60,25 +60,25 @@ spec: env: - name: ENV_PREFIX value: {{ .Values.configurationEnvPrefix }}_ - {{- range $key, $value := .Values.streams.config }} + {{- range $key, $value := .Values.kafka.config }} - name: {{ printf "KAFKA_%s" $key | replace "." "_" | upper | quote }} value: {{ $value | quote }} {{- end }} - {{- if hasKey .Values.streams "brokers" }} + {{- if hasKey .Values.kafka "brokers" }} - name: "{{ .Values.configurationEnvPrefix }}_BROKERS" - value: {{ .Values.streams.brokers | quote }} + value: {{ .Values.kafka.brokers | quote }} {{- end }} - {{- if hasKey .Values.streams "schemaRegistryUrl" }} + {{- if hasKey .Values.kafka "schemaRegistryUrl" }} - name: "{{ .Values.configurationEnvPrefix }}_SCHEMA_REGISTRY_URL" - value: {{ .Values.streams.schemaRegistryUrl | quote }} + value: {{ .Values.kafka.schemaRegistryUrl | quote }} {{- end }} - {{- if hasKey .Values.streams "outputTopic" }} + {{- if hasKey .Values.kafka "outputTopic" }} - name: "{{ .Values.configurationEnvPrefix }}_OUTPUT_TOPIC" - value: {{ .Values.streams.outputTopic | quote }} + value: {{ .Values.kafka.outputTopic | quote }} {{- end }} - {{- if and (hasKey .Values.streams "extraOutputTopics") (.Values.streams.extraOutputTopics) }} + {{- if and (hasKey .Values.kafka "extraOutputTopics") (.Values.kafka.extraOutputTopics) }} - name: "{{ .Values.configurationEnvPrefix }}_EXTRA_OUTPUT_TOPICS" - value: "{{- range $key, $value := .Values.streams.extraOutputTopics }}{{ $key }}={{ $value }},{{- end }}" + value: "{{- range $key, $value := .Values.kafka.extraOutputTopics }}{{ $key }}={{ $value }},{{- end }}" {{- end }} {{- range $key, $value := .Values.secrets }} - name: "{{ $key }}" diff --git a/charts/producer-app-cleanup-job/values.yaml b/charts/producer-app-cleanup-job/values.yaml index 10ba2322..c9aef620 100644 --- a/charts/producer-app-cleanup-job/values.yaml +++ b/charts/producer-app-cleanup-job/values.yaml @@ -15,7 +15,7 @@ files: {} # mountPath: app/resources # content: "foo bar" -streams: +kafka: # brokers: "test:9092" # schemaRegistryUrl: "url:1234" config: {} diff --git a/charts/producer-app/README.md b/charts/producer-app/README.md index d5dd1823..f0ebbab5 100644 --- a/charts/producer-app/README.md +++ b/charts/producer-app/README.md @@ -46,13 +46,13 @@ Alternatively, a YAML file that specifies the values for the parameters can be p ### Streams -| Parameter | Description | Default | -|-----------------------------|------------------------------------------------------------------------------------------------------------|---------| -| `streams.brokers` | Comma separated list of Kafka brokers to connect to. | | -| `streams.schemaRegistryUrl` | URL of Schema Registry to connect to. | `null` | -| `streams.config` | Configurations for your [Kafka producer app](https://kafka.apache.org/documentation/#producerconfigs). | `{}` | -| `streams.outputTopic` | Output topic for your producer application. | | -| `streams.extraOutputTopics` | Map of additional named output topics if you need to specify multiple topics with different message types. | `{}` | +| Parameter | Description | Default | +|---------------------------|------------------------------------------------------------------------------------------------------------|---------| +| `kafka.brokers` | Comma separated list of Kafka brokers to connect to. | | +| `kafka.schemaRegistryUrl` | URL of Schema Registry to connect to. | `null` | +| `kafka.config` | Configurations for your [Kafka producer app](https://kafka.apache.org/documentation/#producerconfigs). | `{}` | +| `kafka.outputTopic` | Output topic for your producer application. | | +| `kafka.extraOutputTopics` | Map of additional named output topics if you need to specify multiple topics with different message types. | `{}` | ### Other diff --git a/charts/producer-app/templates/pod.yaml b/charts/producer-app/templates/pod.yaml index 50bc96e6..ba063e0b 100644 --- a/charts/producer-app/templates/pod.yaml +++ b/charts/producer-app/templates/pod.yaml @@ -44,25 +44,25 @@ spec: env: - name: ENV_PREFIX value: {{ .Values.configurationEnvPrefix }}_ - {{- range $key, $value := .Values.streams.config }} + {{- range $key, $value := .Values.kafka.config }} - name: {{ printf "KAFKA_%s" $key | replace "." "_" | upper | quote }} value: {{ $value | quote }} {{- end }} - {{- if hasKey .Values.streams "brokers" }} + {{- if hasKey .Values.kafka "brokers" }} - name: "{{ .Values.configurationEnvPrefix }}_BROKERS" - value: {{ .Values.streams.brokers | quote }} + value: {{ .Values.kafka.brokers | quote }} {{- end }} - {{- if hasKey .Values.streams "schemaRegistryUrl" }} + {{- if hasKey .Values.kafka "schemaRegistryUrl" }} - name: "{{ .Values.configurationEnvPrefix }}_SCHEMA_REGISTRY_URL" - value: {{ .Values.streams.schemaRegistryUrl | quote }} + value: {{ .Values.kafka.schemaRegistryUrl | quote }} {{- end }} - {{- if hasKey .Values.streams "outputTopic" }} + {{- if hasKey .Values.kafka "outputTopic" }} - name: "{{ .Values.configurationEnvPrefix }}_OUTPUT_TOPIC" - value: {{ .Values.streams.outputTopic | quote }} + value: {{ .Values.kafka.outputTopic | quote }} {{- end }} - {{- if and (hasKey .Values.streams "extraOutputTopics") (.Values.streams.extraOutputTopics) }} + {{- if and (hasKey .Values.kafka "extraOutputTopics") (.Values.kafka.extraOutputTopics) }} - name: "{{ .Values.configurationEnvPrefix }}_EXTRA_OUTPUT_TOPICS" - value: "{{- range $key, $value := .Values.streams.extraOutputTopics }}{{ $key }}={{ $value }},{{- end }}" + value: "{{- range $key, $value := .Values.kafka.extraOutputTopics }}{{ $key }}={{ $value }},{{- end }}" {{- end }} {{- range $key, $value := .Values.secrets }} - name: "{{ $key }}" diff --git a/charts/producer-app/values.yaml b/charts/producer-app/values.yaml index d09628ad..1bd2360c 100644 --- a/charts/producer-app/values.yaml +++ b/charts/producer-app/values.yaml @@ -48,7 +48,7 @@ resources: memory: 2G cpu: 500m -streams: +kafka: # brokers: "test:9092" # schemaRegistryUrl: "url:1234" config: {} diff --git a/charts/streams-app-cleanup-job/templates/job.yaml b/charts/streams-app-cleanup-job/templates/job.yaml index 931f2821..458e58b5 100644 --- a/charts/streams-app-cleanup-job/templates/job.yaml +++ b/charts/streams-app-cleanup-job/templates/job.yaml @@ -56,7 +56,7 @@ spec: resources: {{ toYaml .Values.resources | indent 12 }} args: - {{- if .Values.streams.deleteOutput }} + {{- if .Values.kafka.deleteOutput }} - clean {{- else }} - reset @@ -64,46 +64,46 @@ spec: env: - name: ENV_PREFIX value: {{ .Values.configurationEnvPrefix }}_ - {{- range $key, $value := .Values.streams.config }} + {{- range $key, $value := .Values.kafka.config }} - name: {{ printf "KAFKA_%s" $key | replace "." "_" | upper | quote }} value: {{ $value | quote }} {{- end }} - {{- if hasKey .Values.streams "brokers" }} + {{- if hasKey .Values.kafka "brokers" }} - name: "{{ .Values.configurationEnvPrefix }}_BROKERS" - value: {{ .Values.streams.brokers | quote }} + value: {{ .Values.kafka.brokers | quote }} {{- end }} - {{- if hasKey .Values.streams "schemaRegistryUrl" }} + {{- if hasKey .Values.kafka "schemaRegistryUrl" }} - name: "{{ .Values.configurationEnvPrefix }}_SCHEMA_REGISTRY_URL" - value: {{ .Values.streams.schemaRegistryUrl | quote }} + value: {{ .Values.kafka.schemaRegistryUrl | quote }} {{- end }} - {{- if and (hasKey .Values.streams "inputTopics") (.Values.streams.inputTopics) }} + {{- if and (hasKey .Values.kafka "inputTopics") (.Values.kafka.inputTopics) }} - name: "{{ .Values.configurationEnvPrefix }}_INPUT_TOPICS" - value: {{ .Values.streams.inputTopics | join "," | quote }} + value: {{ .Values.kafka.inputTopics | join "," | quote }} {{- end }} - {{- if hasKey .Values.streams "inputPattern" }} + {{- if hasKey .Values.kafka "inputPattern" }} - name: "{{ .Values.configurationEnvPrefix }}_INPUT_PATTERN" - value: {{ .Values.streams.inputPattern | join "," | quote }} + value: {{ .Values.kafka.inputPattern | join "," | quote }} {{- end }} - {{- if hasKey .Values.streams "outputTopic" }} + {{- if hasKey .Values.kafka "outputTopic" }} - name: "{{ .Values.configurationEnvPrefix }}_OUTPUT_TOPIC" - value: {{ .Values.streams.outputTopic | quote }} + value: {{ .Values.kafka.outputTopic | quote }} {{- end }} - {{- if hasKey .Values.streams "errorTopic" }} + {{- if hasKey .Values.kafka "errorTopic" }} - name: "{{ .Values.configurationEnvPrefix }}_ERROR_TOPIC" - value: {{ .Values.streams.errorTopic | quote }} + value: {{ .Values.kafka.errorTopic | quote }} {{- end }} - {{- if and (hasKey .Values.streams "extraOutputTopics") (.Values.streams.extraOutputTopics) }} + {{- if and (hasKey .Values.kafka "extraOutputTopics") (.Values.kafka.extraOutputTopics) }} - name: "{{ .Values.configurationEnvPrefix }}_EXTRA_OUTPUT_TOPICS" - value: "{{- range $key, $value := .Values.streams.extraOutputTopics }}{{ $key }}={{ $value }},{{- end }}" + value: "{{- range $key, $value := .Values.kafka.extraOutputTopics }}{{ $key }}={{ $value }},{{- end }}" {{- end }} {{- $delimiter := ";" }} - {{- if and (hasKey .Values.streams "extraInputTopics") (.Values.streams.extraInputTopics) }} + {{- if and (hasKey .Values.kafka "extraInputTopics") (.Values.kafka.extraInputTopics) }} - name: "{{ .Values.configurationEnvPrefix }}_EXTRA_INPUT_TOPICS" - value: "{{- range $key, $value := .Values.streams.extraInputTopics }}{{ $key }}={{ $value | join $delimiter }},{{- end }}" + value: "{{- range $key, $value := .Values.kafka.extraInputTopics }}{{ $key }}={{ $value | join $delimiter }},{{- end }}" {{- end }} - {{- if and (hasKey .Values.streams "extraInputPatterns") (.Values.streams.extraInputPatterns) }} + {{- if and (hasKey .Values.kafka "extraInputPatterns") (.Values.kafka.extraInputPatterns) }} - name: "{{ .Values.configurationEnvPrefix }}_EXTRA_INPUT_PATTERNS" - value: "{{- range $key, $value := .Values.streams.extraInputPatterns }}{{ $key }}={{ $value }},{{- end }}" + value: "{{- range $key, $value := .Values.kafka.extraInputPatterns }}{{ $key }}={{ $value }},{{- end }}" {{- end }} {{- range $key, $value := .Values.secrets }} - name: "{{ $key }}" diff --git a/charts/streams-app-cleanup-job/values.yaml b/charts/streams-app-cleanup-job/values.yaml index 029bb730..1620a5cd 100644 --- a/charts/streams-app-cleanup-job/values.yaml +++ b/charts/streams-app-cleanup-job/values.yaml @@ -15,7 +15,7 @@ files: {} # mountPath: app/resources # content: "foo bar" -streams: +kafka: # brokers: "test:9092" # schemaRegistryUrl: "url:1234" config: {} diff --git a/charts/streams-app/README.md b/charts/streams-app/README.md index 5fcc3b47..b5938db3 100644 --- a/charts/streams-app/README.md +++ b/charts/streams-app/README.md @@ -50,20 +50,19 @@ Alternatively, a YAML file that specifies the values for the parameters can be p ### Streams -| Parameter | Description | Default | -|------------------------------|----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|---------| -| `streams.brokers` | Comma separated list of Kafka brokers to connect to. | | -| `streams.schemaRegistryUrl` | URL of Schema Registry to connect to. | `null` | -| `streams.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` | -| `streams.config` | Configurations for your [Kafka Streams app](https://kafka.apache.org/documentation/#streamsconfigs). | `{}` | -| `streams.inputTopics` | List of input topics for your streams application. | `[]` | -| `streams.extraInputTopics` | Map of additional named input topics if you need to specify multiple topics with different message types. | `{}` | -| `streams.inputPattern` | Input pattern of topics for your streams application. | | -| `streams.extraInputPatterns` | Map of additional named input patterns if you need to specify multiple topics with different message types. | `{}` | -| `streams.outputTopic` | Output topic for your streams application. | | -| `streams.extraOutputTopics` | Map of additional named output topics if you need to specify multiple topics with different message types. | `{}` | -| `streams.errorTopic` | Error topic for your streams application. | | -| `streams.productive` | Whether to use Kafka configuration values that are more suitable for production environments. | `true` | +| Parameter | Description | Default | +|----------------------------|----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------|---------| +| `kafka.brokers` | Comma separated list of Kafka brokers 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.extraInputTopics` | Map of additional named input topics if you need to specify multiple topics with different message types. | `{}` | +| `kafka.inputPattern` | Input pattern of topics for your streams application. | | +| `kafka.extraInputPatterns` | Map of additional named input patterns if you need to specify multiple topics with different message types. | `{}` | +| `kafka.outputTopic` | Output topic for your streams application. | | +| `kafka.extraOutputTopics` | Map of additional named output topics if you need to specify multiple topics with different message types. | `{}` | +| `kafka.errorTopic` | Error topic for your streams application. | | ### Other diff --git a/charts/streams-app/templates/deployment.yaml b/charts/streams-app/templates/deployment.yaml index 2c061ca2..3da02578 100644 --- a/charts/streams-app/templates/deployment.yaml +++ b/charts/streams-app/templates/deployment.yaml @@ -87,7 +87,7 @@ spec: env: - name: ENV_PREFIX value: {{ .Values.configurationEnvPrefix }}_ - {{- range $key, $value := .Values.streams.config }} + {{- range $key, $value := .Values.kafka.config }} - name: {{ printf "KAFKA_%s" $key | replace "." "_" | upper | quote }} value: {{ $value | quote }} {{- end }} @@ -101,7 +101,7 @@ spec: value: "$(POD_IP):{{ .containerPort }}" {{- end }} {{- end }} - {{- if .Values.streams.staticMembership }} + {{- if .Values.kafka.staticMembership }} - name: KAFKA_GROUP_INSTANCE_ID valueFrom: fieldRef: @@ -115,42 +115,42 @@ spec: - name: "{{ .Values.configurationEnvPrefix }}_VOLATILE_GROUP_INSTANCE_ID" value: "true" {{- end }} - {{- if hasKey .Values.streams "brokers" }} + {{- if hasKey .Values.kafka "brokers" }} - name: "{{ .Values.configurationEnvPrefix }}_BROKERS" - value: {{ .Values.streams.brokers | quote }} + value: {{ .Values.kafka.brokers | quote }} {{- end }} - {{- if hasKey .Values.streams "schemaRegistryUrl" }} + {{- if hasKey .Values.kafka "schemaRegistryUrl" }} - name: "{{ .Values.configurationEnvPrefix }}_SCHEMA_REGISTRY_URL" - value: {{ .Values.streams.schemaRegistryUrl | quote }} + value: {{ .Values.kafka.schemaRegistryUrl | quote }} {{- end }} - {{- if and (hasKey .Values.streams "inputTopics") (.Values.streams.inputTopics) }} + {{- if and (hasKey .Values.kafka "inputTopics") (.Values.kafka.inputTopics) }} - name: "{{ .Values.configurationEnvPrefix }}_INPUT_TOPICS" - value: {{ .Values.streams.inputTopics | join "," | quote }} + value: {{ .Values.kafka.inputTopics | join "," | quote }} {{- end }} - {{- if hasKey .Values.streams "inputPattern" }} + {{- if hasKey .Values.kafka "inputPattern" }} - name: "{{ .Values.configurationEnvPrefix }}_INPUT_PATTERN" - value: {{ .Values.streams.inputPattern | quote }} + value: {{ .Values.kafka.inputPattern | quote }} {{- end }} - {{- if hasKey .Values.streams "outputTopic" }} + {{- if hasKey .Values.kafka "outputTopic" }} - name: "{{ .Values.configurationEnvPrefix }}_OUTPUT_TOPIC" - value: {{ .Values.streams.outputTopic | quote }} + value: {{ .Values.kafka.outputTopic | quote }} {{- end }} - {{- if hasKey .Values.streams "errorTopic" }} + {{- if hasKey .Values.kafka "errorTopic" }} - name: "{{ .Values.configurationEnvPrefix }}_ERROR_TOPIC" - value: {{ .Values.streams.errorTopic | quote }} + value: {{ .Values.kafka.errorTopic | quote }} {{- end }} - {{- if and (hasKey .Values.streams "extraOutputTopics") (.Values.streams.extraOutputTopics) }} + {{- if and (hasKey .Values.kafka "extraOutputTopics") (.Values.kafka.extraOutputTopics) }} - name: "{{ .Values.configurationEnvPrefix }}_EXTRA_OUTPUT_TOPICS" - value: "{{- range $key, $value := .Values.streams.extraOutputTopics }}{{ $key }}={{ $value }},{{- end }}" + value: "{{- range $key, $value := .Values.kafka.extraOutputTopics }}{{ $key }}={{ $value }},{{- end }}" {{- end }} {{- $delimiter := ";" }} - {{- if and (hasKey .Values.streams "extraInputTopics") (.Values.streams.extraInputTopics) }} + {{- if and (hasKey .Values.kafka "extraInputTopics") (.Values.kafka.extraInputTopics) }} - name: "{{ .Values.configurationEnvPrefix }}_EXTRA_INPUT_TOPICS" - value: "{{- range $key, $value := .Values.streams.extraInputTopics }}{{ $key }}={{ $value | join $delimiter }},{{- end }}" + value: "{{- range $key, $value := .Values.kafka.extraInputTopics }}{{ $key }}={{ $value | join $delimiter }},{{- end }}" {{- end }} - {{- if and (hasKey .Values.streams "extraInputPatterns") (.Values.streams.extraInputPatterns) }} + {{- if and (hasKey .Values.kafka "extraInputPatterns") (.Values.kafka.extraInputPatterns) }} - name: "{{ .Values.configurationEnvPrefix }}_EXTRA_INPUT_PATTERNS" - value: "{{- range $key, $value := .Values.streams.extraInputPatterns }}{{ $key }}={{ $value }},{{- end }}" + value: "{{- range $key, $value := .Values.kafka.extraInputPatterns }}{{ $key }}={{ $value }},{{- end }}" {{- end }} {{- range $key, $value := .Values.secrets }} - name: "{{ $key }}" diff --git a/charts/streams-app/templates/scaled-object.yaml b/charts/streams-app/templates/scaled-object.yaml index 85b23303..f214c732 100644 --- a/charts/streams-app/templates/scaled-object.yaml +++ b/charts/streams-app/templates/scaled-object.yaml @@ -26,15 +26,15 @@ spec: idleReplicaCount: {{ .Values.autoscaling.idleReplicas }} {{- end }} triggers: - {{- if not (or .Values.streams.inputTopics .Values.autoscaling.internalTopics .Values.autoscaling.topics .Values.streams.extraInputTopics .Values.autoscaling.additionalTriggers) }} - {{- fail "To use autoscaling, you must define one of .Values.streams.inputTopics, .Values.autoscaling.internalTopics, .Values.autoscaling.topics, .Values.streams.extraInputTopics or .Values.autoscaling.additionalTriggers" }} + {{- if not (or .Values.kafka.inputTopics .Values.autoscaling.internalTopics .Values.autoscaling.topics .Values.kafka.extraInputTopics .Values.autoscaling.additionalTriggers) }} + {{- fail "To use autoscaling, you must define one of .Values.kafka.inputTopics, .Values.autoscaling.internalTopics, .Values.autoscaling.topics, .Values.kafka.extraInputTopics or .Values.autoscaling.additionalTriggers" }} {{- end}} - # todo: concat .Values.streams.inputTopics and .Values.autoscaling.topics to + # todo: concat .Values.kafka.inputTopics and .Values.autoscaling.topics to # minimize number of loops when we don't need to support helm 2 anymore - {{- range .Values.streams.inputTopics }} + {{- range .Values.kafka.inputTopics }} - type: kafka metadata: - bootstrapServers: {{ $root.Values.streams.brokers }} + bootstrapServers: {{ $root.Values.kafka.brokers }} consumerGroup: {{ $root.Values.autoscaling.consumerGroup }} topic: {{ . | quote }} lagThreshold: {{ $root.Values.autoscaling.lagThreshold | quote }} @@ -43,7 +43,7 @@ spec: {{- range .Values.autoscaling.internalTopics }} - type: kafka metadata: - bootstrapServers: {{ $root.Values.streams.brokers }} + bootstrapServers: {{ $root.Values.kafka.brokers }} consumerGroup: {{ $root.Values.autoscaling.consumerGroup }} topic: {{ printf "%s-%s" $root.Values.autoscaling.consumerGroup . | quote }} lagThreshold: {{ $root.Values.autoscaling.lagThreshold | quote }} @@ -52,17 +52,17 @@ spec: {{- range .Values.autoscaling.topics }} - type: kafka metadata: - bootstrapServers: {{ $root.Values.streams.brokers }} + bootstrapServers: {{ $root.Values.kafka.brokers }} consumerGroup: {{ $root.Values.autoscaling.consumerGroup }} topic: {{ . | quote }} lagThreshold: {{ $root.Values.autoscaling.lagThreshold | quote }} offsetResetPolicy: {{ $root.Values.autoscaling.offsetResetPolicy }} {{- end }} - {{- range $key, $value := .Values.streams.extraInputTopics }} + {{- range $key, $value := .Values.kafka.extraInputTopics }} {{- range $topic := $value }} - type: kafka metadata: - bootstrapServers: {{ $root.Values.streams.brokers }} + bootstrapServers: {{ $root.Values.kafka.brokers }} consumerGroup: {{ $root.Values.autoscaling.consumerGroup }} topic: {{ $topic | quote }} lagThreshold: {{ $root.Values.autoscaling.lagThreshold | quote }} diff --git a/charts/streams-app/values.yaml b/charts/streams-app/values.yaml index ee6b8681..0425122f 100644 --- a/charts/streams-app/values.yaml +++ b/charts/streams-app/values.yaml @@ -23,7 +23,7 @@ resources: cpu: 500m memory: 2G -streams: +kafka: # brokers: "test:9092" # schemaRegistryUrl: "url:1234" staticMembership: false @@ -105,7 +105,7 @@ autoscaling: minReplicas: 0 maxReplicas: 1 # idleReplicas: 0 - ## all topics from streams.inputTopics and streams.extraInputTopics are automatically taken + ## all topics from kafka.inputTopics and kafka.extraInputTopics are automatically taken ## only use the 'internalTopics' option for adding internal topics, i.e., auto-generated topics by Kafka Streams. Consumer group name will automatically be added as a prefix internalTopics: [] # - bar-repartition # results in foo-bar-repartition