diff --git a/tests/integration/test_storage_kafka/test.py b/tests/integration/test_storage_kafka/test.py
index d77a7c56cf4..6c06d7401bd 100644
--- a/tests/integration/test_storage_kafka/test.py
+++ b/tests/integration/test_storage_kafka/test.py
@@ -2859,8 +2859,8 @@ def test_kafka_formats_with_broken_message(kafka_cluster):
                 val3 UInt8
             ) ENGINE = Kafka()
                 SETTINGS kafka_broker_list = 'kafka1:19092',
-                        kafka_topic_list = '{topic_name}',
-                        kafka_group_name = '{topic_name}_group',
+                        kafka_topic_list = 'stream_{topic_name}',
+                        kafka_group_name = 'stream_{topic_name}_group',
                         kafka_format = '{format_name}',
                         kafka_handle_error_mode = 'stream',
                         kafka_flush_interval_ms = 1000 {extra_settings};
@@ -2877,8 +2877,6 @@ def test_kafka_formats_with_broken_message(kafka_cluster):
             '''.format(topic_name=topic_name, format_name=format_name, raw_message=raw_message,
                        extra_settings=format_opts.get('extra_settings') or ''))
 
-            #DROP TABLE IF EXISTS test.kafka_errors_{format_name}_mv;
-
     for format_name, format_opts in list(all_formats.items()):
         print(('Checking {}'.format(format_name)))
         topic_name = 'format_tests_{}'.format(format_name)