From 16e971ee5254574a57cb0a091ad739eab69d222c Mon Sep 17 00:00:00 2001 From: Peng Jian Date: Thu, 8 Apr 2021 07:19:57 +0800 Subject: [PATCH] fix test case --- tests/integration/test_storage_kafka/test.py | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) 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)