From 62615f90b1a8a639a6f0d2e7f66eee3648132162 Mon Sep 17 00:00:00 2001 From: Alexey Milovidov Date: Wed, 10 Jun 2026 18:15:53 -0700 Subject: [PATCH] Merge pull request #106975 from ClickHouse/backport/26.3/105222 Backport #105222 to 26.3: Update submodule --- contrib/librdkafka | 2 +- tests/integration/test_kafka_bad_messages/test_1.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/contrib/librdkafka b/contrib/librdkafka index cd9a80837602..6aa06cfec6ae 160000 --- a/contrib/librdkafka +++ b/contrib/librdkafka @@ -1 +1 @@ -Subproject commit cd9a80837602fe0f97c146beff752e705f40cb0a +Subproject commit 6aa06cfec6ae35efb6e6f895326ed0ec2ecc2a27 diff --git a/tests/integration/test_kafka_bad_messages/test_1.py b/tests/integration/test_kafka_bad_messages/test_1.py index cc778944e68a..36b40427f486 100644 --- a/tests/integration/test_kafka_bad_messages/test_1.py +++ b/tests/integration/test_kafka_bad_messages/test_1.py @@ -113,7 +113,7 @@ def test_log_to_exceptions(kafka_cluster, max_retries=20): logging.debug(f"system.kafka_consumers content: {system_kafka_consumers_content}") assert system_kafka_consumers_content.startswith( - f"[thrd:localhost:{non_existent_broker_port}/bootstrap]: localhost:{non_existent_broker_port}/bootstrap: Connect to ipv4#127.0.0.1:{non_existent_broker_port} failed: Connection refused" + f"[thrd:localhost:{non_existent_broker_port}/bootstrap]: 1/1 brokers are down" ) instance.query("DROP TABLE foo_exceptions")