From 1629ab5328e4c51a010e9396d875c8d4f1e95663 Mon Sep 17 00:00:00 2001 From: Baodi Shi Date: Tue, 16 May 2023 22:42:29 +0800 Subject: [PATCH] Fix batch receive for C client unit test faied. --- tests/c/c_ConsumerTest.cc | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/tests/c/c_ConsumerTest.cc b/tests/c/c_ConsumerTest.cc index 1c64cba8..d824c8f6 100644 --- a/tests/c/c_ConsumerTest.cc +++ b/tests/c/c_ConsumerTest.cc @@ -46,8 +46,8 @@ static void batch_receive_callback(pulsar_result async_result, pulsar_messages_t char expected_str[128]; snprintf(expected_str, sizeof(expected_str), "msg-%d", 10 + i); - printf("%d received: %s (%zd), expected: %s (%zd)\n", i, str, strlen(str), expected_str, - strlen(expected_str)); + printf("async batch %d received: %s (%zd), expected: %s (%zd)\n", i, str, strlen(str), + expected_str, strlen(expected_str)); ASSERT_EQ(strcmp(str, expected_str), 0); free(str); } @@ -110,7 +110,6 @@ TEST(c_ConsumerTest, testBatchReceive) { std::future receive_future = receive_promise.get_future(); struct batch_receive_ctx batch_receive_ctx = {consumer, &receive_promise, batch_receive_max_size}; pulsar_consumer_batch_receive_async(consumer, batch_receive_callback, &batch_receive_ctx); - pulsar_client_close(client); ASSERT_EQ(pulsar_result_Ok, receive_future.get()); pulsar_client_close(client);