Skip to content

Commit 57d8766

Browse files
committed
bump librdkafka after bugs were fixed
See confluentinc/librdkafka#5057
1 parent 619146d commit 57d8766

File tree

4 files changed

+5
-3
lines changed

4 files changed

+5
-3
lines changed

librdkafka

Submodule librdkafka updated 158 files

tests/consumer.lua

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -252,7 +252,7 @@ local function test_create_errors()
252252

253253
log.info('Create with incompatible properties')
254254
local _, err = tnt_kafka.Consumer.create({brokers = '', options = {['reconnect.backoff.max.ms'] = '2', ['reconnect.backoff.ms'] = '1000'}})
255-
assert(err == '`reconnect.backoff.max.ms` must be >= `reconnect.max.ms`')
255+
assert(err == '`reconnect.backoff.max.ms` must be >= `reconnect.backoff.ms`')
256256
end
257257

258258
return {

tests/producer.lua

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -142,7 +142,7 @@ local function test_create_errors()
142142

143143
log.info('Create with incompatible properties')
144144
local _, err = tnt_kafka.Producer.create({brokers = '', options = {['reconnect.backoff.max.ms'] = '2', ['reconnect.backoff.ms'] = '1000'}})
145-
assert(err == '`reconnect.backoff.max.ms` must be >= `reconnect.max.ms`')
145+
assert(err == '`reconnect.backoff.max.ms` must be >= `reconnect.backoff.ms`')
146146
end
147147

148148
return {

tests/test_consumer.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -262,6 +262,7 @@ def test_consumer_should_partially_unsubscribe_from_topics():
262262

263263
write_into_kafka("test_unsub_partially_1", (message1, ))
264264
write_into_kafka("test_unsub_partially_2", (message2, ))
265+
time.sleep(2)
265266

266267
# waiting up to 30 seconds
267268
response = server.call("consumer.consume", [30])[0]
@@ -275,6 +276,7 @@ def test_consumer_should_partially_unsubscribe_from_topics():
275276

276277
write_into_kafka("test_unsub_partially_1", (message3, ))
277278
write_into_kafka("test_unsub_partially_2", (message4, ))
279+
time.sleep(2)
278280

279281
response = server.call("consumer.consume", [30])[0]
280282

0 commit comments

Comments
 (0)