feat: Support Vector 0.58.0

CHANGELOG.md

@@ -69,7 +69,7 @@ All notable changes to this project will be documented in this file.
 - The operator now watches all resources that it creates and early-exits the reconcile action when the
   cluster is marked for deletion ([#882]).
 - Make operations infallible where dependent on static inputs ([#886], [#889]).
-- test: Bump vector-aggregator to 0.58.0 ([#899]).
+- Support Vector 0.58.0 ([#899], [#905]).
 - test: Bump opa latest to 1.20.2, removed 1.12.3 ([#901]).
 - Update docs to version 1.20.2 ([#903]).
 - All pods now set `securityContext.seccompProfile.type` to `RuntimeDefault` ([#904]).
@@ -109,6 +109,7 @@ All notable changes to this project will be documented in this file.
 [#901]: https://github.com/stackabletech/opa-operator/pull/901
 [#903]: https://github.com/stackabletech/opa-operator/pull/903
 [#904]: https://github.com/stackabletech/opa-operator/pull/904
+[#905]: https://github.com/stackabletech/opa-operator/pull/905
 
 ## [26.7.0] - 2026-07-21
 

rust/operator-binary/src/controller/build/properties/product_logging/test-vector.sh

@@ -1,11 +1,19 @@
 #!/usr/bin/env sh
 
-DATA_DIR=/stackable/log/_vector-state \
-LOG_DIR=/stackable/log \
-NAMESPACE=default \
-CLUSTER_NAME=opa \
-ROLE_NAME=server \
-ROLE_GROUP_NAME=default \
-VECTOR_AGGREGATOR_ADDRESS=vector-aggregator \
-VECTOR_FILE_LOG_LEVEL=info \
+set -eu
+
+export DATA_DIR=/stackable/log/_vector-state
+export LOG_DIR=/stackable/log
+export NAMESPACE=default
+export CLUSTER_NAME=opa
+export ROLE_NAME=server
+export ROLE_GROUP_NAME=default
+export VECTOR_AGGREGATOR_ADDRESS=http://vector-aggregator:6000
+export VECTOR_FILE_LOG_LEVEL=info
+
+# Required because vector.yaml contains ${...} placeholders
+export VECTOR_DANGEROUSLY_ALLOW_ENV_VAR_INTERPOLATION=true
+
+vector validate --no-environment vector.yaml
+
 vector test vector.yaml vector-test.yaml

rust/operator-binary/src/controller/build/properties/product_logging/vector-test.yaml

@@ -16,6 +16,7 @@ tests:
           source_type: file
     outputs:
       - extract_from: extended_logs
+        expected_event_count: 1
         conditions:
           - type: vrl
             source: |
@@ -41,6 +42,7 @@ tests:
           source_type: file
     outputs:
       - extract_from: extended_logs
+        expected_event_count: 1
         conditions:
           - type: vrl
             source: |
@@ -60,6 +62,7 @@ tests:
           source_type: file
     outputs:
       - extract_from: extended_logs
+        expected_event_count: 1
         conditions:
           - type: vrl
             source: |
@@ -77,6 +80,7 @@ tests:
           source_type: file
     outputs:
       - extract_from: extended_logs
+        expected_event_count: 1
         conditions:
           - type: vrl
             source: |
@@ -97,6 +101,7 @@ tests:
           source_type: file
     outputs:
       - extract_from: extended_logs
+        expected_event_count: 1
         conditions:
           - type: vrl
             source: |
@@ -113,6 +118,7 @@ tests:
           source_type: file
     outputs:
       - extract_from: extended_logs
+        expected_event_count: 1
         conditions:
           - type: vrl
             source: |
@@ -131,6 +137,7 @@ tests:
           source_type: file
     outputs:
       - extract_from: extended_logs
+        expected_event_count: 1
         conditions:
           - type: vrl
             source: |
@@ -152,6 +159,7 @@ tests:
           source_type: internal_logs
     outputs:
       - extract_from: extended_logs
+        expected_event_count: 1
         conditions:
           - type: vrl
             source: |
@@ -169,6 +177,7 @@ tests:
             level: INFO
     outputs:
       - extract_from: filtered_logs_vector
+        expected_event_count: 1
         conditions:
           - type: vrl
             source: |

rust/operator-binary/src/controller/build/properties/product_logging/vector.yaml

@@ -202,7 +202,10 @@ transforms:
   # Extends the processed files with the fields "container" and "file"
   extended_logs_files:
     inputs:
-      - processed_files_*
+      - processed_files_stdout
+      - processed_files_stderr
+      - processed_files_tracing_rs
+      - processed_files_opa_json
     type: remap
     source: |
       del(.source_type)
@@ -242,7 +245,8 @@ transforms:
   # Add the fields "namespace", "cluster", "role" and "roleGroup" to all logs
   extended_logs:
     inputs:
-      - extended_logs_*
+      - extended_logs_files
+      - extended_logs_vector
     type: remap
     source: |
       .namespace = "${NAMESPACE}"
@@ -256,4 +260,8 @@ sinks:
     inputs:
       - extended_logs
     type: vector
-    address: ${VECTOR_AGGREGATOR_ADDRESS}
+    routing:
+      endpoints:
+        - ${VECTOR_AGGREGATOR_ADDRESS}
+    compression: zstd
+    keepalive: {}

tests/templates/kuttl/logging/01-install-opa-vector-aggregator.yaml

@@ -14,4 +14,4 @@ kind: ConfigMap
 metadata:
   name: opa-vector-aggregator-discovery
 data:
-  ADDRESS: opa-vector-aggregator:6123
+  ADDRESS: http://opa-vector-aggregator:6123