From 82774f9202134934dff6665fe6f8a6919da99f10 Mon Sep 17 00:00:00 2001 From: Emanuele Sabellico Date: Sat, 6 Apr 2024 13:00:53 +0200 Subject: [PATCH] Test --- .semaphore/semaphore.yml | 1 + tests/0147-consumer_group_consumer_mock.c | 7 ++++++- 2 files changed, 7 insertions(+), 1 deletion(-) diff --git a/.semaphore/semaphore.yml b/.semaphore/semaphore.yml index bd18e3a5af..16c7d043d7 100644 --- a/.semaphore/semaphore.yml +++ b/.semaphore/semaphore.yml @@ -33,6 +33,7 @@ blocks: - otool -L src/librdkafka.dylib - otool -L src-cpp/librdkafka++.dylib - make -j -C tests build + - TEST_DEBUG=all TESTS=0147 make -C tests run_local_quick - make -C tests run_local_quick - DESTDIR="$PWD/dest" make install - (cd dest && tar cvzf ../artifacts/librdkafka.tgz .) diff --git a/tests/0147-consumer_group_consumer_mock.c b/tests/0147-consumer_group_consumer_mock.c index 045a2136f5..c96767729f 100644 --- a/tests/0147-consumer_group_consumer_mock.c +++ b/tests/0147-consumer_group_consumer_mock.c @@ -490,11 +490,13 @@ do_test_consumer_group_heartbeat_fenced_error(rd_kafka_resp_err_t err, rebalance_exp_event = RD_KAFKA_RESP_ERR__ASSIGN_PARTITIONS; rebalance_exp_lost = rd_false; + TEST_SAY("Clearing mock requests\n"); rd_kafka_mock_clear_requests(mcluster); expected_heartbeats = 0; + TEST_SAY("Awaiting rebalance callback\n"); /* Consume from c, partitions are lost if assigned */ - rkmessage = rd_kafka_consumer_poll(c, 1000); + rkmessage = rd_kafka_consumer_poll(c, 500); TEST_ASSERT(!rkmessage, "No message should be returned"); TEST_ASSERT(rebalance_cnt == expected_rebalance_cnt, @@ -509,6 +511,8 @@ do_test_consumer_group_heartbeat_fenced_error(rd_kafka_resp_err_t err, * Second HB acks assignment */ expected_heartbeats += 2; } + + TEST_SAY("Awaiting acknowledge heartbeat\n"); TEST_ASSERT((found_heartbeats = wait_all_heartbeats_done(mcluster, expected_heartbeats, 100)) == expected_heartbeats, @@ -526,6 +530,7 @@ do_test_consumer_group_heartbeat_fenced_error(rd_kafka_resp_err_t err, "Expected %d rebalance events, got %d", expected_rebalance_cnt, rebalance_cnt); + TEST_SAY("Awaiting leave group heartbeat\n"); /* After closing the consumer, 1 heartbeat should been sent */ TEST_ASSERT((found_heartbeats = wait_all_heartbeats_done(mcluster, 1, 200)) == 1,