add sleep

This commit is contained in:
Yatsishin Ilya 2021-01-29 19:09:48 +03:00
parent 01c9b90144
commit ac168fe4e3

View File

@ -105,6 +105,8 @@ def test_kafka_json_as_string(kafka_cluster):
kafka_flush_interval_ms=1000;
''')
time.sleep(3)
result = instance.query('SELECT * FROM test.kafka;')
expected = '''\
{"t": 123, "e": {"x": "woof"} }