run pre commit

maltesander · maltesander · commit d654a978a5bc · 2025-09-05T16:12:15.000+02:00
diff --git a/.vscode/launch.json b/.vscode/launch.json
@@ -20,4 +20,4 @@
             "cwd": "${workspaceFolder}"
         }
     ]
-}
+}
diff --git a/docs/modules/kafka/pages/usage-guide/kraft-controller.adoc b/docs/modules/kafka/pages/usage-guide/kraft-controller.adoc
@@ -1,7 +1,7 @@
 = KRaft
 :description: Apache Kafka KRaft mode with the Stackable Operator for Apache Kafka
 
-Apache Kafka's KRaft mode (Kafka Raft Metadata mode) replaces Apache ZooKeeper with Kafka’s own built-in consensus mechanism based on the Raft protocol. 
+Apache Kafka's KRaft mode (Kafka Raft Metadata mode) replaces Apache ZooKeeper with Kafka’s own built-in consensus mechanism based on the Raft protocol.
 This simplifies Kafka’s architecture, reducing operational complexity by consolidating cluster metadata management into Kafka itself.
 
 WARNING: The Stackable Operator for Apache Kafka currently does not support automatic cluster upgrades from Apache ZooKeeper to KRaft.
@@ -76,7 +76,7 @@ controllers:
 
 === Overrides
 
-== Internal operator details  
+== Internal operator details
 
 KRaft mode requires major configuration changes compared to ZooKeeper:
 
diff --git a/rust/operator-binary/src/config/command.rs b/rust/operator-binary/src/config/command.rs
@@ -151,12 +151,12 @@ pub fn controller_kafka_container_command(
         echo \"{KAFKA_LISTENER_SECURITY_PROTOCOL_MAP}={listener_security_protocol_map}\" >> /tmp/{properties_file}
         echo \"{KAFKA_CONTROLLER_QUORUM_VOTERS}={controller_quorum_voters}\" >> /tmp/{properties_file}
 
-        bin/kafka-storage.sh format --cluster-id {cluster_id} --config /tmp/{properties_file} --ignore-formatted {initial_controller_command} 
+        bin/kafka-storage.sh format --cluster-id {cluster_id} --config /tmp/{properties_file} --ignore-formatted {initial_controller_command}
         bin/kafka-server-start.sh /tmp/{properties_file} &
 
         wait_for_termination $!
         {create_vector_shutdown_file_command}
-        ", 
+        ",
         remove_vector_shutdown_file_command = remove_vector_shutdown_file_command(STACKABLE_LOG_DIR),
         config_dir = STACKABLE_CONFIG_DIR,
         properties_file = CONTROLLER_PROPERTIES_FILE,
diff --git a/tests/templates/kuttl/cluster-operation/20-install-kafka.yaml.j2 b/tests/templates/kuttl/cluster-operation/20-install-kafka.yaml.j2
@@ -16,7 +16,7 @@ spec:
     productVersion: "{{ test_scenario['values']['kafka-latest'] }}"
 {% endif %}
     pullPolicy: IfNotPresent
-{% if lookup('env', 'VECTOR_AGGREGATOR') or test_scenario['values']['use-kraft-controller'] == 'false' %}    
+{% if lookup('env', 'VECTOR_AGGREGATOR') or test_scenario['values']['use-kraft-controller'] == 'false' %}
   clusterConfig:
 {% endif %}
 {% if lookup('env', 'VECTOR_AGGREGATOR') %}
diff --git a/tests/templates/kuttl/cluster-operation/30-stop-kafka.yaml.j2 b/tests/templates/kuttl/cluster-operation/30-stop-kafka.yaml.j2
@@ -16,7 +16,7 @@ spec:
     productVersion: "{{ test_scenario['values']['kafka-latest'] }}"
 {% endif %}
     pullPolicy: IfNotPresent
-{% if lookup('env', 'VECTOR_AGGREGATOR') or test_scenario['values']['use-kraft-controller'] == 'false' %}    
+{% if lookup('env', 'VECTOR_AGGREGATOR') or test_scenario['values']['use-kraft-controller'] == 'false' %}
   clusterConfig:
 {% endif %}
 {% if lookup('env', 'VECTOR_AGGREGATOR') %}
diff --git a/tests/templates/kuttl/cluster-operation/40-pause-kafka.yaml.j2 b/tests/templates/kuttl/cluster-operation/40-pause-kafka.yaml.j2
@@ -16,7 +16,7 @@ spec:
     productVersion: "{{ test_scenario['values']['kafka-latest'] }}"
 {% endif %}
     pullPolicy: IfNotPresent
-{% if lookup('env', 'VECTOR_AGGREGATOR') or test_scenario['values']['use-kraft-controller'] == 'false' %}    
+{% if lookup('env', 'VECTOR_AGGREGATOR') or test_scenario['values']['use-kraft-controller'] == 'false' %}
   clusterConfig:
 {% endif %}
 {% if lookup('env', 'VECTOR_AGGREGATOR') %}
diff --git a/tests/templates/kuttl/cluster-operation/50-restart-kafka.yaml.j2 b/tests/templates/kuttl/cluster-operation/50-restart-kafka.yaml.j2
@@ -15,7 +15,7 @@ spec:
 {% else %}
     productVersion: "{{ test_scenario['values']['kafka-latest'] }}"
 {% endif %}
-{% if lookup('env', 'VECTOR_AGGREGATOR') or test_scenario['values']['use-kraft-controller'] == 'false' %}    
+{% if lookup('env', 'VECTOR_AGGREGATOR') or test_scenario['values']['use-kraft-controller'] == 'false' %}
   clusterConfig:
 {% endif %}
 {% if lookup('env', 'VECTOR_AGGREGATOR') %}
diff --git a/tests/templates/kuttl/delete-rolegroup/02-assert.yaml.j2 b/tests/templates/kuttl/delete-rolegroup/02-assert.yaml.j2
@@ -35,4 +35,4 @@ metadata:
 status:
   readyReplicas: 1
   replicas: 1
-{% endif %}  
+{% endif %}
diff --git a/tests/templates/kuttl/delete-rolegroup/02-install-kafka.yaml.j2 b/tests/templates/kuttl/delete-rolegroup/02-install-kafka.yaml.j2
@@ -27,13 +27,13 @@ spec:
     config:
       gracefulShutdownTimeout: 30s # speed up tests
       logging:
-        enableVectorAgent: {{ lookup('env', 'VECTOR_AGGREGATOR') | length > 0 }}  
+        enableVectorAgent: {{ lookup('env', 'VECTOR_AGGREGATOR') | length > 0 }}
     roleGroups:
       default:
         replicas: 2
       secondary:
         replicas: 1
-{% endif %}  
+{% endif %}
   brokers:
     config:
       gracefulShutdownTimeout: 30s # speed up tests
diff --git a/tests/templates/kuttl/delete-rolegroup/03-assert.yaml.j2 b/tests/templates/kuttl/delete-rolegroup/03-assert.yaml.j2
@@ -19,4 +19,4 @@ metadata:
 status:
   readyReplicas: 2
   replicas: 2
-{% endif %}  
+{% endif %}
diff --git a/tests/templates/kuttl/delete-rolegroup/03-delete-secondary.yaml.j2 b/tests/templates/kuttl/delete-rolegroup/03-delete-secondary.yaml.j2
@@ -26,12 +26,12 @@ spec:
     config:
       gracefulShutdownTimeout: 30s # speed up tests
       logging:
-        enableVectorAgent: {{ lookup('env', 'VECTOR_AGGREGATOR') | length > 0 }}  
+        enableVectorAgent: {{ lookup('env', 'VECTOR_AGGREGATOR') | length > 0 }}
     roleGroups:
       default:
         replicas: 2
       secondary: null
-{% endif %}  
+{% endif %}
   brokers:
     config:
       gracefulShutdownTimeout: 30s # speed up tests
diff --git a/tests/templates/kuttl/logging/test_log_aggregation.py b/tests/templates/kuttl/logging/test_log_aggregation.py
@@ -4,9 +4,9 @@
 
 def check_sent_events():
     response = requests.post(
-        'http://kafka-vector-aggregator:8686/graphql',
+        "http://kafka-vector-aggregator:8686/graphql",
         json={
-            'query': """
+            "query": """
                 {
                     transforms(first:100) {
                         nodes {
@@ -20,29 +20,30 @@ def check_sent_events():
                     }
                 }
             """
-        }
+        },
     )
 
-    assert response.status_code == 200, \
-        'Cannot access the API of the vector aggregator.'
+    assert response.status_code == 200, (
+        "Cannot access the API of the vector aggregator."
+    )
 
     result = response.json()
 
-    transforms = result['data']['transforms']['nodes']
+    transforms = result["data"]["transforms"]["nodes"]
     for transform in transforms:
-        sentEvents = transform['metrics']['sentEventsTotal']
-        componentId = transform['componentId']
+        sentEvents = transform["metrics"]["sentEventsTotal"]
+        componentId = transform["componentId"]
 
-        if componentId == 'filteredInvalidEvents':
-            assert sentEvents is None or \
-                   sentEvents['sentEventsTotal'] == 0, \
-                   'Invalid log events were sent.'
+        if componentId == "filteredInvalidEvents":
+            assert sentEvents is None or sentEvents["sentEventsTotal"] == 0, (
+                "Invalid log events were sent."
+            )
         else:
-            assert sentEvents is not None and \
-                   sentEvents['sentEventsTotal'] > 0, \
-                   f'No events were sent in "{componentId}".'
+            assert sentEvents is not None and sentEvents["sentEventsTotal"] > 0, (
+                f'No events were sent in "{componentId}".'
+            )
 
 
-if __name__ == '__main__':
+if __name__ == "__main__":
     check_sent_events()
-    print('Test successful!')
+    print("Test successful!")
diff --git a/tests/templates/kuttl/smoke/30-install-kafka.yaml.j2 b/tests/templates/kuttl/smoke/30-install-kafka.yaml.j2
@@ -40,7 +40,7 @@ spec:
     roleGroups:
       default:
         replicas: 3
-{% endif %}    
+{% endif %}
   brokers:
     configOverrides:
       broker.properties:
diff --git a/tests/templates/kuttl/smoke/metrics.py b/tests/templates/kuttl/smoke/metrics.py
@@ -5,8 +5,12 @@
 if __name__ == "__main__":
     result = 0
 
-    LOG_LEVEL = 'DEBUG'  # if args.debug else 'INFO'
-    logging.basicConfig(level=LOG_LEVEL, format='%(asctime)s %(levelname)s: %(message)s', stream=sys.stdout)
+    LOG_LEVEL = "DEBUG"  # if args.debug else 'INFO'
+    logging.basicConfig(
+        level=LOG_LEVEL,
+        format="%(asctime)s %(levelname)s: %(message)s",
+        stream=sys.stdout,
+    )
 
     http_code = requests.get("http://test-kafka-broker-default:9606").status_code
     if http_code != 200:
diff --git a/tests/templates/kuttl/upgrade/02-install-kafka.yaml.j2 b/tests/templates/kuttl/upgrade/02-install-kafka.yaml.j2
@@ -60,11 +60,11 @@ spec:
     config:
       gracefulShutdownTimeout: 30s # speed up tests
       logging:
-        enableVectorAgent: {{ lookup('env', 'VECTOR_AGGREGATOR') | length > 0 }}  
+        enableVectorAgent: {{ lookup('env', 'VECTOR_AGGREGATOR') | length > 0 }}
     roleGroups:
       default:
         replicas: 3
-{% endif %}   
+{% endif %}
   brokers:
     config:
       gracefulShutdownTimeout: 30s # speed up tests

Original file line number	Diff line number	Diff line change
`@@ -20,4 +20,4 @@`
`20`	`20`	`"cwd": "${workspaceFolder}"`
`21`	`21`	`}`
`22`	`22`	`]`
`23`		`-}`
	`23`	`+}`