test: Adapt the integration tests to Vector 0.58.0

CHANGELOG.md

@@ -20,7 +20,7 @@ All notable changes to this project will be documented in this file.
   always defaulting to `Always` ([#994]).
 - Internal operator refactoring: introduce a build() step in the reconciler that
   assembles all relevant Kubernetes resources before anything is applied ([#961]).
-- Bump stackable-operator to 0.118.0 ([#970], [#994]).
+- Bump stackable-operator to 0.121.0 ([#970], [#994], [#999], [#1011]).
 - The RBAC ServiceAccount and RoleBinding are now built with the operator-rs `v2::rbac`
   functions and carry the full set of recommended labels ([#966]).
 - BREAKING: The `nodes` role is now required by the CRD; a NifiCluster without it was
@@ -47,9 +47,8 @@ All notable changes to this project will be documented in this file.
   operator immediately recreates it with the new labels ([#984]).
 - Make operations infallible where dependent on static inputs ([#990]).
 - Deprecate support for 2.9.0 ([#997]).
-- Bump stackable-operator to 0.119.0 ([#999]).
-- Support Vector 0.58.0 ([#1006], [#1012]).
-- Bump stackable-operator to 0.121.0 and replace the unmaintained `serde_yaml` with `yaml_serde` ([#1011]).
+- Support Vector 0.58.0 ([#1006], [#1012], [#1013]).
+- Replace the unmaintained `serde_yaml` with `yaml_serde` ([#1011]).
 - All pods now set `securityContext.seccompProfile.type` to `RuntimeDefault` ([#1011]).
 - test: Update OPA to 1.20.2 in integration tests ([#1010]).
 
@@ -83,6 +82,7 @@ All notable changes to this project will be documented in this file.
 [#1010]: https://github.com/stackabletech/nifi-operator/pull/1010
 [#1011]: https://github.com/stackabletech/nifi-operator/pull/1011
 [#1012]: https://github.com/stackabletech/nifi-operator/pull/1012
+[#1013]: https://github.com/stackabletech/nifi-operator/pull/1013
 
 ## [26.7.0] - 2026-07-21
 

tests/templates/kuttl/logging/nifi-vector-aggregator-values.yaml.j2

@@ -76,7 +76,9 @@ customConfig:
     aggregator:
       inputs: [vector]
       type: vector
-      address: {{ lookup('env', 'VECTOR_AGGREGATOR') }}
+      routing:
+        endpoints:
+          - {{ lookup('env', 'VECTOR_AGGREGATOR') }}
       buffer:
         # Avoid back pressure from VECTOR_AGGREGATOR. The test should
         # not fail if the aggregator is not available.

tests/templates/kuttl/smoke/35-assert.yaml.j2

@@ -387,7 +387,9 @@ commands:
           # Extends the processed files with the fields "container" and "file"
           extended_logs_files:
             inputs:
-              - processed_files_*
+              - processed_files_stdout
+              - processed_files_stderr
+              - processed_files_log4j
             type: remap
             source: |
               del(.source_type)
@@ -425,7 +427,8 @@ commands:
           # 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}"
@@ -439,7 +442,11 @@ commands:
             inputs:
               - extended_logs
             type: vector
-            address: ${VECTOR_AGGREGATOR_ADDRESS}
+            routing:
+              endpoints:
+                - ${VECTOR_AGGREGATOR_ADDRESS}
+            compression: zstd
+            keepalive: {}
 {% endif %}
       YAMLEOF
       )