Skip to content

Commit c62ebfe

Browse files
committed
test_consumer_poll: make mv optional
1 parent d693989 commit c62ebfe

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

tests/test.c

+3-2
Original file line numberDiff line numberDiff line change
@@ -2473,7 +2473,8 @@ int test_consumer_poll (const char *what, rd_kafka_t *rk, uint64_t testid,
24732473
rd_kafka_topic_name(rkmessage->rkt),
24742474
rkmessage->partition,
24752475
rkmessage->offset);
2476-
test_msgver_add_msg(mv, rkmessage);
2476+
if (mv)
2477+
test_msgver_add_msg(mv, rkmessage);
24772478
eof_cnt++;
24782479

24792480
} else if (rkmessage->err) {
@@ -2487,7 +2488,7 @@ int test_consumer_poll (const char *what, rd_kafka_t *rk, uint64_t testid,
24872488
rd_kafka_message_errstr(rkmessage));
24882489

24892490
} else {
2490-
if (test_msgver_add_msg(mv, rkmessage))
2491+
if (!mv || test_msgver_add_msg(mv, rkmessage))
24912492
cnt++;
24922493
}
24932494

0 commit comments

Comments
 (0)