Test

confluentinc · Apr 6, 2024 · 82774f9 · 82774f9
1 parent 99f4833
commit 82774f9
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git 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
@@ -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,