diff --git a/tests/integration/test_storage_kafka/test.py b/tests/integration/test_storage_kafka/test.py
index ceff95fcfd5..ca14079c19a 100644
--- a/tests/integration/test_storage_kafka/test.py
+++ b/tests/integration/test_storage_kafka/test.py
@@ -4908,7 +4908,7 @@ def test_formats_errors(kafka_cluster):
         kafka_produce(
             kafka_cluster,
             format_name,
-            ["Broken message\nBroken message\nBroken message\n"]
+            ["Broken message\nBroken message\nBroken message\n"],
         )
 
         attempt = 0