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")