Add batch processor preset

Author: povilasv

charts/opentelemetry-collector/CHANGELOG.md

@@ -2,6 +2,9 @@
 
 ## OpenTelemetry Collector
 
+## v0.115.2 / 2025-05-22
+- [Feat] Add batch processor preset
+
 ## v0.115.1 / 2025-05-19
 - [Update] `kubeletstatsreceiver`: set `collect_all_network_interfaces` on `pods`
 

charts/opentelemetry-collector/Chart.yaml

@@ -1,6 +1,6 @@
 apiVersion: v2
 name: opentelemetry-collector
-version: 0.115.1
+version: 0.115.2
 description: OpenTelemetry Collector Helm chart for Kubernetes
 type: application
 home: https://opentelemetry.io/

charts/opentelemetry-collector/templates/_config.tpl

@@ -112,6 +112,9 @@ Build config file for daemonset OpenTelemetry Collector
 {{- if .Values.presets.zipkinReceiver.enabled }}
 {{- $config = (include "opentelemetry-collector.applyZipkinReceiverConfig" (dict "Values" $data "config" $config) | fromYaml) }}
 {{- end }}
+{{- if .Values.presets.batch.enabled }}
+{{- $config = (include "opentelemetry-collector.applyBatchProcessorConfig" (dict "Values" $data "config" $config) | fromYaml) }}
+{{- end }}
 {{- $config = (include "opentelemetry-collector.applyBatchProcessorAsLast" (dict "Values" $data "config" $config) | fromYaml) }}
 {{- tpl (toYaml $config) . }}
 {{- end }}
@@ -192,6 +195,9 @@ Build config file for deployment OpenTelemetry Collector
 {{- if .Values.presets.zipkinReceiver.enabled }}
 {{- $config = (include "opentelemetry-collector.applyZipkinReceiverConfig" (dict "Values" $data "config" $config) | fromYaml) }}
 {{- end }}
+{{- if .Values.presets.batch.enabled }}
+{{- $config = (include "opentelemetry-collector.applyBatchProcessorConfig" (dict "Values" $data "config" $config) | fromYaml) }}
+{{- end }}
 {{- $config = (include "opentelemetry-collector.applyBatchProcessorAsLast" (dict "Values" $data "config" $config) | fromYaml) }}
 {{- $config = (include "opentelemetry-collector.applyMemoryLimiterProcessorAsFirst" (dict "Values" $data "config" $config) | fromYaml) }}
 {{- tpl (toYaml $config) . }}
@@ -1784,3 +1790,25 @@ receivers:
   zipkin:
     endpoint: ${env:MY_POD_IP}:9411
 {{- end }}
+
+{{- define "opentelemetry-collector.applyBatchProcessorConfig" -}}
+{{- $config := mustMergeOverwrite (include "opentelemetry-collector.batchProcessorConfig" .Values | fromYaml) .config }}
+{{- if and ($config.service.pipelines.logs) (not (has "batch" $config.service.pipelines.logs.processors)) }}
+{{- $_ := set $config.service.pipelines.logs "processors" (append $config.service.pipelines.logs.processors "batch" | uniq) }}
+{{- end }}
+{{- if and ($config.service.pipelines.metrics) (not (has "batch" $config.service.pipelines.metrics.processors)) }}
+{{- $_ := set $config.service.pipelines.metrics "processors" (append $config.service.pipelines.metrics.processors "batch" | uniq) }}
+{{- end }}
+{{- if and ($config.service.pipelines.traces) (not (has "batch" $config.service.pipelines.traces.processors)) }}
+{{- $_ := set $config.service.pipelines.traces "processors" (append $config.service.pipelines.traces.processors "batch" | uniq) }}
+{{- end }}
+{{- $config | toYaml }}
+{{- end }}
+
+{{- define "opentelemetry-collector.batchProcessorConfig" -}}
+processors:
+  batch:
+    send_batch_size: {{ .Values.presets.batch.sendBatchSize }}
+    send_batch_max_size: {{ .Values.presets.batch.sendBatchMaxSize }}
+    timeout: {{ .Values.presets.batch.timeout }}
+{{- end }}

charts/opentelemetry-collector/values.schema.json

@@ -855,6 +855,28 @@
               "type": "boolean"
             }
           }
+        },
+        "batch": {
+          "type": "object",
+          "additionalProperties": false,
+          "properties": {
+            "enabled": {
+              "description": "Specifies whether the batch processor preset is applied.",
+              "type": "boolean"
+            },
+            "sendBatchSize": {
+              "description": "Specifies the send_batch_size for the batch processor.",
+              "type": "integer"
+            },
+            "sendBatchMaxSize": {
+              "description": "Specifies the send_batch_max_size for the batch processor.",
+              "type": "integer"
+            },
+            "timeout": {
+              "description": "Specifies the timeout for the batch processor.",
+              "type": "string"
+            }
+          }
         }
       }
     },

charts/opentelemetry-collector/values.yaml

@@ -393,6 +393,13 @@ presets:
   zipkinReceiver:
     enabled: false
 
+  # Configuration for the batch processor.
+  batch:
+    enabled: false
+    sendBatchSize: 1024
+    sendBatchMaxSize: 2048
+    timeout: "1s"
+
 configMap:
   # Specifies whether a configMap should be created (true by default)
   create: true