| /dports/net/librdkafka/librdkafka-1.8.2/tests/ |
| H A D | 0069-consumer_add_parts.c | 91 test_consumer_poll_no_msgs("wait-rebalance", c1, 0, 1000); in main_0069_consumer_add_parts()
92 test_consumer_poll_no_msgs("wait-rebalance", c2, 0, 1000); in main_0069_consumer_add_parts()
107 test_consumer_poll_no_msgs("wait-stable", c2, 0, 1000); in main_0069_consumer_add_parts()
|
| H A D | 0104-fetch_from_follower_mock.c | 93 test_consumer_poll_no_msgs(auto_offset_reset, c, 0, 5000); in do_test_offset_reset()
161 test_consumer_poll_no_msgs("no msgs", c, 0, 3000); in do_test_offset_reset_lag()
221 test_consumer_poll_no_msgs("unknown follower", c, 0, 5000); in do_test_unknown_follower()
300 test_consumer_poll_no_msgs("Wait initial metadata", c, 0, 2000); in do_test_replica_not_available()
|
| H A D | 0026-consume_pause.c | 174 test_consumer_poll_no_msgs("silence.while.paused", in consume_pause()
208 test_consumer_poll_no_msgs("end.exp.no.msgs", rk, testid, 3000); in consume_pause()
289 test_consumer_poll_no_msgs("silence.while.paused", rk, testid, 3000); in consume_pause_resume_after_reassign()
|
| H A D | 0028-long_topicnames.c | 68 test_consumer_poll_no_msgs("consume.nomsgs", rk_c, 0, 5000); in main_0028_long_topicnames()
|
| H A D | 0102-static_group_rebalance.c | 338 test_consumer_poll_no_msgs("wait.max.poll", c[0].rk, testid, in do_test_static_group_rebalance()
418 test_consumer_poll_no_msgs("poll", c[i], 0, timeout_ms); in await_assignment_multi()
487 test_consumer_poll_no_msgs("consumer1", c[1], 0, 5000); in do_test_fenced_member()
|
| H A D | 0050-subscribe_adds.c | 108 test_consumer_poll_no_msgs("consume", rk, testid, (int)(6000*1.5)); in main_0050_subscribe_adds()
|
| H A D | 0051-assign_adds.c | 111 test_consumer_poll_no_msgs("consume", rk, testid, (int)(6000*1.5)); in main_0051_assign_adds()
|
| H A D | 0015-offset_seeks.c | 109 test_consumer_poll_no_msgs("NO.MSGS", c, testid, 3000); in do_seek()
|
| H A D | 0030-offset_commit.c | 234 test_consumer_poll_no_msgs(what, rk, testid, 0); in do_offset_test()
253 test_consumer_poll_no_msgs(what, rk, testid, 1000); in do_offset_test()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
| H A D | 0069-consumer_add_parts.c | 89 test_consumer_poll_no_msgs("wait-rebalance", c1, 0, 1000); in main_0069_consumer_add_parts()
90 test_consumer_poll_no_msgs("wait-rebalance", c2, 0, 1000); in main_0069_consumer_add_parts()
105 test_consumer_poll_no_msgs("wait-stable", c2, 0, 1000); in main_0069_consumer_add_parts()
|
| H A D | 0104-fetch_from_follower_mock.c | 93 test_consumer_poll_no_msgs(auto_offset_reset, c, 0, 5000); in do_test_offset_reset()
161 test_consumer_poll_no_msgs("no msgs", c, 0, 3000); in do_test_offset_reset_lag()
220 test_consumer_poll_no_msgs("unknown follower", c, 0, 5000); in do_test_unknown_follower()
|
| H A D | 0026-consume_pause.c | 174 test_consumer_poll_no_msgs("silence.while.paused", in consume_pause()
208 test_consumer_poll_no_msgs("end.exp.no.msgs", rk, testid, 3000); in consume_pause()
289 test_consumer_poll_no_msgs("silence.while.paused", rk, testid, 3000); in consume_pause_resume_after_reassign()
|
| H A D | 0028-long_topicnames.c | 68 test_consumer_poll_no_msgs("consume.nomsgs", rk_c, 0, 5000); in main_0028_long_topicnames()
|
| H A D | 0102-static_group_rebalance.c | 330 test_consumer_poll_no_msgs("wait.max.poll", c[0].rk, testid, in do_test_static_group_rebalance()
408 test_consumer_poll_no_msgs("poll", c[i], 0, timeout_ms); in await_assignment_multi()
475 test_consumer_poll_no_msgs("consumer1", c[1], 0, 5000); in do_test_fenced_member()
|
| H A D | 0050-subscribe_adds.c | 108 test_consumer_poll_no_msgs("consume", rk, testid, (int)(6000*1.5)); in main_0050_subscribe_adds()
|
| H A D | 0051-assign_adds.c | 111 test_consumer_poll_no_msgs("consume", rk, testid, (int)(6000*1.5)); in main_0051_assign_adds()
|
| H A D | 0030-offset_commit.c | 228 test_consumer_poll_no_msgs(what, rk, testid, 0); in do_offset_test()
247 test_consumer_poll_no_msgs(what, rk, testid, 1000); in do_offset_test()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
| H A D | 0069-consumer_add_parts.c | 91 test_consumer_poll_no_msgs("wait-rebalance", c1, 0, 1000);
92 test_consumer_poll_no_msgs("wait-rebalance", c2, 0, 1000);
107 test_consumer_poll_no_msgs("wait-stable", c2, 0, 1000);
|
| H A D | 0104-fetch_from_follower_mock.c | 93 test_consumer_poll_no_msgs(auto_offset_reset, c, 0, 5000); in do_test_offset_reset()
161 test_consumer_poll_no_msgs("no msgs", c, 0, 3000); in do_test_offset_reset_lag()
221 test_consumer_poll_no_msgs("unknown follower", c, 0, 5000); in do_test_unknown_follower()
300 test_consumer_poll_no_msgs("Wait initial metadata", c, 0, 2000); in do_test_replica_not_available()
|
| H A D | 0026-consume_pause.c | 174 test_consumer_poll_no_msgs("silence.while.paused",
208 test_consumer_poll_no_msgs("end.exp.no.msgs", rk, testid, 3000);
289 test_consumer_poll_no_msgs("silence.while.paused", rk, testid, 3000);
|
| H A D | 0028-long_topicnames.c | 68 test_consumer_poll_no_msgs("consume.nomsgs", rk_c, 0, 5000); in main_0028_long_topicnames()
|
| H A D | 0102-static_group_rebalance.c | 338 test_consumer_poll_no_msgs("wait.max.poll", c[0].rk, testid, in do_test_static_group_rebalance()
418 test_consumer_poll_no_msgs("poll", c[i], 0, timeout_ms); in await_assignment_multi()
487 test_consumer_poll_no_msgs("consumer1", c[1], 0, 5000); in do_test_fenced_member()
|
| H A D | 0050-subscribe_adds.c | 108 test_consumer_poll_no_msgs("consume", rk, testid, (int)(6000*1.5));
|
| H A D | 0051-assign_adds.c | 111 test_consumer_poll_no_msgs("consume", rk, testid, (int)(6000*1.5)); in main_0051_assign_adds()
|
| H A D | 0015-offset_seeks.c | 109 test_consumer_poll_no_msgs("NO.MSGS", c, testid, 3000); in do_seek()
|