/dports/net/librdkafka/librdkafka-1.8.2/tests/ |
H A D | 0109-auto_create_topics.cpp | 52 test_broker_version >= TEST_BRKVER(2,1,0,0) && in do_test_consumer() 56 bool supports_allow = test_broker_version >= TEST_BRKVER(0,11,0,0); in do_test_consumer()
|
H A D | 0016-client_swname.c | 120 else if (test_broker_version < TEST_BRKVER(2,5,0,0)) in main_0016_client_swname()
|
H A D | 0057-invalid_topic.cpp | 60 if (test_broker_version >= TEST_BRKVER(0,8,2,2)) in dr_cb()
|
H A D | 0084-destroy_flags.c | 184 test_broker_version >= TEST_BRKVER(0,9,0,0); in destroy_flags()
|
H A D | 0081-admin.c | 90 test_broker_version >= TEST_BRKVER(2,4,0,0); in do_test_CreateTopics() 778 if (test_broker_version >= TEST_BRKVER(1, 1, 0, 0)) { in do_test_AlterConfigs() 813 if (test_broker_version >= TEST_BRKVER(2, 7, 0, 0)) in do_test_AlterConfigs() 989 if (test_broker_version < TEST_BRKVER(2,0,0,0)) in do_test_DescribeConfigs() 1930 if (test_broker_version >= TEST_BRKVER(1,0,0,0)) { in do_test_apis() 1953 if (test_broker_version >= TEST_BRKVER(2,4,0,0)) { in do_test_apis()
|
H A D | 0029-assign_offset.c | 153 if (test_broker_version >= TEST_BRKVER(0,9,0,0)) { in main_0029_assign_offset()
|
H A D | 0070-null_empty.cpp | 184 if (test_broker_version >= TEST_BRKVER(0,10,0,0)) in main_0070_null_empty()
|
H A D | test.c | 61 int test_broker_version; variable 1241 if (test_broker_version && in run_tests() 1242 (test->minver > test_broker_version || in run_tests() 1247 TEST_BRKVER_X(test_broker_version, 0), in run_tests() 1248 TEST_BRKVER_X(test_broker_version, 1), in run_tests() 1249 TEST_BRKVER_X(test_broker_version, 2), in run_tests() 1250 TEST_BRKVER_X(test_broker_version, 3)); in run_tests() 1714 TEST_BRKVER_X(test_broker_version, 0), in main() 1715 TEST_BRKVER_X(test_broker_version, 1), in main() 1716 TEST_BRKVER_X(test_broker_version, 2), in main() [all …]
|
H A D | 0076-produce_retry.c | 316 test_broker_version >= TEST_BRKVER(0,11,0,0); in main_0076_produce_retry()
|
H A D | 0086-purge.c | 297 test_broker_version >= TEST_BRKVER(0,11,0,0); in main_0086_purge_remote()
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
H A D | 0109-auto_create_topics.cpp | 52 test_broker_version >= TEST_BRKVER(2,1,0,0) && in do_test_consumer() 56 bool supports_allow = test_broker_version >= TEST_BRKVER(0,11,0,0); in do_test_consumer()
|
H A D | 0016-client_swname.c | 120 else if (test_broker_version < TEST_BRKVER(2,5,0,0))
|
H A D | 0057-invalid_topic.cpp | 60 if (test_broker_version >= TEST_BRKVER(0,8,2,2)) in dr_cb()
|
H A D | 0084-destroy_flags.c | 184 test_broker_version >= TEST_BRKVER(0,9,0,0);
|
H A D | test.c | 61 int test_broker_version; variable 1233 if (test_broker_version && in run_tests() 1234 (test->minver > test_broker_version || in run_tests() 1239 TEST_BRKVER_X(test_broker_version, 0), in run_tests() 1240 TEST_BRKVER_X(test_broker_version, 1), in run_tests() 1241 TEST_BRKVER_X(test_broker_version, 2), in run_tests() 1242 TEST_BRKVER_X(test_broker_version, 3)); in run_tests() 1706 TEST_BRKVER_X(test_broker_version, 0), in main() 1707 TEST_BRKVER_X(test_broker_version, 1), in main() 1708 TEST_BRKVER_X(test_broker_version, 2), in main() [all …]
|
H A D | 0081-admin.c | 90 test_broker_version >= TEST_BRKVER(2,4,0,0); in do_test_CreateTopics() 778 if (test_broker_version >= TEST_BRKVER(1, 1, 0, 0)) { in do_test_AlterConfigs() 813 if (test_broker_version >= TEST_BRKVER(2, 7, 0, 0)) in do_test_AlterConfigs() 989 if (test_broker_version < TEST_BRKVER(2,0,0,0)) in do_test_DescribeConfigs() 1930 if (test_broker_version >= TEST_BRKVER(1,0,0,0)) { in do_test_apis() 1953 if (test_broker_version >= TEST_BRKVER(2,4,0,0)) { in do_test_apis()
|
H A D | 0029-assign_offset.c | 153 if (test_broker_version >= TEST_BRKVER(0,9,0,0)) {
|
H A D | 0070-null_empty.cpp | 184 if (test_broker_version >= TEST_BRKVER(0,10,0,0)) in main_0070_null_empty()
|
H A D | 0103-transactions.c | 803 rd_bool_t expect_fail = test_broker_version < TEST_BRKVER(2,5,0,0); in do_test_fatal_idempo_error_without_kip360() 810 if (test_broker_version >= TEST_BRKVER(2,4,0,0) && in do_test_fatal_idempo_error_without_kip360() 811 test_broker_version < TEST_BRKVER(2,5,0,0)) in do_test_fatal_idempo_error_without_kip360()
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
H A D | 0016-client_swname.c | 120 else if (test_broker_version < TEST_BRKVER(2,5,0,0)) in main_0016_client_swname()
|
H A D | 0057-invalid_topic.cpp | 60 if (test_broker_version >= TEST_BRKVER(0,8,2,2)) in dr_cb()
|
H A D | test.c | 61 int test_broker_version; variable 1177 if (test_broker_version && in run_tests() 1178 (test->minver > test_broker_version || in run_tests() 1183 TEST_BRKVER_X(test_broker_version, 0), in run_tests() 1184 TEST_BRKVER_X(test_broker_version, 1), in run_tests() 1185 TEST_BRKVER_X(test_broker_version, 2), in run_tests() 1186 TEST_BRKVER_X(test_broker_version, 3)); in run_tests() 1637 TEST_BRKVER_X(test_broker_version, 0), in main() 1638 TEST_BRKVER_X(test_broker_version, 1), in main() 1639 TEST_BRKVER_X(test_broker_version, 2), in main() [all …]
|
H A D | 0084-destroy_flags.c | 184 test_broker_version >= TEST_BRKVER(0,9,0,0); in destroy_flags()
|
H A D | 0029-assign_offset.c | 153 if (test_broker_version >= TEST_BRKVER(0,9,0,0)) { in main_0029_assign_offset()
|
H A D | 0070-null_empty.cpp | 184 if (test_broker_version >= TEST_BRKVER(0,10,0,0)) in main_0070_null_empty()
|