diff --git a/librdkafka b/librdkafka
index b4c6085..826f585 160000
--- a/librdkafka
+++ b/librdkafka
@@ -1 +1 @@
-Subproject commit b4c608570f796c18ff2211a7af876046d264d392
+Subproject commit 826f585564ec33750e9211c7eeb801d3f85a91a0
diff --git a/tests/consumer.lua b/tests/consumer.lua
index 89f77b0..e47f720 100644
--- a/tests/consumer.lua
+++ b/tests/consumer.lua
@@ -252,7 +252,7 @@ local function test_create_errors()
 
     log.info('Create with incompatible properties')
     local _, err = tnt_kafka.Consumer.create({brokers = '', options = {['reconnect.backoff.max.ms'] = '2', ['reconnect.backoff.ms'] = '1000'}})
-    assert(err == '`reconnect.backoff.max.ms` must be >= `reconnect.max.ms`')
+    assert(err == '`reconnect.backoff.max.ms` must be >= `reconnect.backoff.ms`')
 end
 
 return {
diff --git a/tests/producer.lua b/tests/producer.lua
index 2959d67..7fb71b2 100644
--- a/tests/producer.lua
+++ b/tests/producer.lua
@@ -142,7 +142,7 @@ local function test_create_errors()
 
     log.info('Create with incompatible properties')
     local _, err = tnt_kafka.Producer.create({brokers = '', options = {['reconnect.backoff.max.ms'] = '2', ['reconnect.backoff.ms'] = '1000'}})
-    assert(err == '`reconnect.backoff.max.ms` must be >= `reconnect.max.ms`')
+    assert(err == '`reconnect.backoff.max.ms` must be >= `reconnect.backoff.ms`')
 end
 
 return {
diff --git a/tests/test_consumer.py b/tests/test_consumer.py
index 0027b2b..f9358fd 100644
--- a/tests/test_consumer.py
+++ b/tests/test_consumer.py
@@ -262,6 +262,7 @@ def test_consumer_should_partially_unsubscribe_from_topics():
 
         write_into_kafka("test_unsub_partially_1", (message1, ))
         write_into_kafka("test_unsub_partially_2", (message2, ))
+        time.sleep(5)
 
         # waiting up to 30 seconds
         response = server.call("consumer.consume", [30])[0]
@@ -275,6 +276,7 @@ def test_consumer_should_partially_unsubscribe_from_topics():
 
         write_into_kafka("test_unsub_partially_1", (message3, ))
         write_into_kafka("test_unsub_partially_2", (message4, ))
+        time.sleep(5)
 
         response = server.call("consumer.consume", [30])[0]