Revert "avoid race in librdkafka"

This reverts commit bd8c3eb117.
2024-09-20 08:40:50 +00:00 · 2021-05-04 10:06:33 +02:00 · 2021-05-04 10:06:33 +02:00 · 80065b08f8
commit 80065b08f8
parent ba7945367e
1 changed files with 0 additions and 2 deletions
--- a/tests/integration/test_storage_kafka/test.py
+++ b/tests/integration/test_storage_kafka/test.py
@ -2467,8 +2467,6 @@ def test_kafka_issue14202(kafka_cluster):
                     kafka_format = 'JSONEachRow';
        ''')

-    time.sleep(3)
-
    instance.query(
        'INSERT INTO test.kafka_q SELECT t, some_string  FROM ( SELECT dt AS t, some_string FROM test.empty_table )')
    # check instance is alive