thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-10 01:25:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix the test after #20393

Browse Source
This commit is contained in:
Mikhail Filimonov 2021-06-04 15:55:07 +02:00
parent f1733a93e5
commit c8fe168a8d
No known key found for this signature in database
GPG Key ID: 6E49C2E9AF1220BE
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
tests/integration/test_storage_kafka/test.py
View File

@ -1320,7 +1320,8 @@ def test_librdkafka_compression(kafka_cluster):
logging.debug(('Check compression {}'.format(compression_type)))
topic_name = 'test_librdkafka_compression_{}'.format(compression_type)
admin_client = admin.AdminClient({'bootstrap.servers': 'localhost:9092'})
admin_client = admin.AdminClient({'bootstrap.servers': "localhost:{}".format(kafka_cluster.kafka_port)})
topic = admin.NewTopic(topic=topic_name, num_partitions=1, replication_factor=1, config={
'compression.type': compression_type,
})