Home
last modified time | relevance | path

Searched refs:test_broker_version (Results 1 – 25 of 43) sorted by relevance

12

/dports/net/librdkafka/librdkafka-1.8.2/tests/
H A D0109-auto_create_topics.cpp52 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 D0016-client_swname.c120 else if (test_broker_version < TEST_BRKVER(2,5,0,0)) in main_0016_client_swname()
H A D0057-invalid_topic.cpp60 if (test_broker_version >= TEST_BRKVER(0,8,2,2)) in dr_cb()
H A D0084-destroy_flags.c184 test_broker_version >= TEST_BRKVER(0,9,0,0); in destroy_flags()
H A D0081-admin.c90 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 D0029-assign_offset.c153 if (test_broker_version >= TEST_BRKVER(0,9,0,0)) { in main_0029_assign_offset()
H A D0070-null_empty.cpp184 if (test_broker_version >= TEST_BRKVER(0,10,0,0)) in main_0070_null_empty()
H A Dtest.c61 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 D0076-produce_retry.c316 test_broker_version >= TEST_BRKVER(0,11,0,0); in main_0076_produce_retry()
H A D0086-purge.c297 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 D0109-auto_create_topics.cpp52 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 D0016-client_swname.c120 else if (test_broker_version < TEST_BRKVER(2,5,0,0))
H A D0057-invalid_topic.cpp60 if (test_broker_version >= TEST_BRKVER(0,8,2,2)) in dr_cb()
H A D0084-destroy_flags.c184 test_broker_version >= TEST_BRKVER(0,9,0,0);
H A Dtest.c61 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 D0081-admin.c90 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 D0029-assign_offset.c153 if (test_broker_version >= TEST_BRKVER(0,9,0,0)) {
H A D0070-null_empty.cpp184 if (test_broker_version >= TEST_BRKVER(0,10,0,0)) in main_0070_null_empty()
H A D0103-transactions.c803 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 D0016-client_swname.c120 else if (test_broker_version < TEST_BRKVER(2,5,0,0)) in main_0016_client_swname()
H A D0057-invalid_topic.cpp60 if (test_broker_version >= TEST_BRKVER(0,8,2,2)) in dr_cb()
H A Dtest.c61 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 D0084-destroy_flags.c184 test_broker_version >= TEST_BRKVER(0,9,0,0); in destroy_flags()
H A D0029-assign_offset.c153 if (test_broker_version >= TEST_BRKVER(0,9,0,0)) { in main_0029_assign_offset()
H A D0070-null_empty.cpp184 if (test_broker_version >= TEST_BRKVER(0,10,0,0)) in main_0070_null_empty()

12