/dports/net/librdkafka/librdkafka-1.8.2/tests/ |
H A D | 0050-subscribe_adds.c | 50 rd_strdup(test_mk_topic_name("0050_subscribe_adds_1", 1)), in main_0050_subscribe_adds() 51 rd_strdup(test_mk_topic_name("0050_subscribe_adds_2", 1)), in main_0050_subscribe_adds() 52 rd_strdup(test_mk_topic_name("0050_subscribe_adds_3", 1)), in main_0050_subscribe_adds()
|
H A D | 0051-assign_adds.c | 50 rd_strdup(test_mk_topic_name("0051_assign_adds_1", 1)), in main_0051_assign_adds() 51 rd_strdup(test_mk_topic_name("0051_assign_adds_2", 1)), in main_0051_assign_adds() 52 rd_strdup(test_mk_topic_name("0051_assign_adds_3", 1)), in main_0051_assign_adds()
|
H A D | 0045-subscribe_update.c | 142 char *topic_a = rd_strdup(test_mk_topic_name("topic_a", 1)); in do_test_non_exist_and_partchange() 204 char *base_topic = rd_strdup(test_mk_topic_name("topic", 1)); in do_test_regex() 279 char *topic_f = rd_strdup(test_mk_topic_name("topic_f", 1)); in do_test_topic_remove() 280 char *topic_g = rd_strdup(test_mk_topic_name("topic_g", 1)); in do_test_topic_remove()
|
H A D | 0011-produce_batch.c | 101 rkt = rd_kafka_topic_new(rk, test_mk_topic_name("0011", 0), in test_single_partition() 221 rkt = rd_kafka_topic_new(rk, test_mk_topic_name("0011", 0), in test_partitioner() 337 topic_name = test_mk_topic_name("0011_per_message_flag", 1); in test_per_message_partition_flag() 472 rkt = rd_kafka_topic_new(rk, test_mk_topic_name("0011", 0), in test_message_partitioner_wo_per_message_flag()
|
H A D | 0103-transactions.c | 98 const char *topic = test_mk_topic_name("0103_transactions", 1); in do_test_basic_producer_txn() 309 rd_strdup(test_mk_topic_name("0103-transactions-input", 1)); in do_test_consumer_producer_txn() 311 rd_strdup(test_mk_topic_name("0103-transactions-output", 1)); in do_test_consumer_producer_txn() 532 const char *topic = test_mk_topic_name("0103-test_misuse_txn", 1); in do_test_misuse_txn() 699 const char *topic = test_mk_topic_name("0103_fenced_txn", 1); in do_test_fenced_txn() 789 const char *topic = test_mk_topic_name("0103_fatal_idempo", 1); in do_test_fatal_idempo_error_without_kip360() 970 const char *topic = test_mk_topic_name("0103_empty_txn", 1); in do_test_empty_txn() 1085 const char *topic = test_mk_topic_name("0103_wmark_isol", 1); in do_test_wmark_isolation_level()
|
H A D | 0033-regex_subscribe.c | 297 test_mk_topic_name("regex_subscribe_TOPIC_0001_UNO", 0), in do_test() 301 test_mk_topic_name("regex_subscribe_topic_0002_dup", 0), in do_test() 305 test_mk_topic_name("regex_subscribe_TOOTHPIC_0003_3", 0), in do_test() 312 test_mk_topic_name("regex_subscribe_NONEXISTENT_0004_IV#!", in do_test()
|
H A D | 0002-unkpart.c | 91 rkt = rd_kafka_topic_new(rk, test_mk_topic_name("0002", 0), in do_test_unkpart() 174 const char *topic = test_mk_topic_name("0002_unkpart_tmout", 0); in do_test_unkpart_timeout_nobroker()
|
H A D | 0081-admin.c | 88 char *topic = rd_strdup(test_mk_topic_name(__FUNCTION__, 1)); in do_test_CreateTopics() 333 char *topic = rd_strdup(test_mk_topic_name(__FUNCTION__, 1)); in do_test_DeleteTopics() 535 char *topic = rd_strdup(test_mk_topic_name(__FUNCTION__, 1)); in do_test_CreatePartitions() 754 rd_strdupa(&topics[i], test_mk_topic_name(__FUNCTION__, 1)); in do_test_AlterConfigs() 955 rd_strdupa(&topics[0], test_mk_topic_name("DescribeConfigs_exist", 1)); in do_test_DescribeConfigs() 958 test_mk_topic_name("DescribeConfigs_notexist", 1)); in do_test_DescribeConfigs() 1148 topic = rd_kafka_NewTopic_new(test_mk_topic_name(__FUNCTION__, 1), in do_test_unclean_destroy() 1219 topic = rd_strdup(test_mk_topic_name(pfx, 1)); in do_test_DeleteRecords() 1508 topic = rd_strdup(test_mk_topic_name(__FUNCTION__, 1)); in do_test_DeleteGroups() 1526 char *group = rd_strdup(test_mk_topic_name(__FUNCTION__, 1)); in do_test_DeleteGroups() [all …]
|
H A D | 0026-consume_pause.c | 44 const char *topic = test_mk_topic_name(__FUNCTION__, 1); in consume_pause() 238 const char *topic = test_mk_topic_name(__FUNCTION__, 1); in consume_pause_resume_after_reassign() 397 const char *topic = test_mk_topic_name(__FUNCTION__, 1); in consume_subscribe_assign_pause_resume()
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
H A D | 0050-subscribe_adds.c | 50 rd_strdup(test_mk_topic_name("0050_subscribe_adds_1", 1)), in main_0050_subscribe_adds() 51 rd_strdup(test_mk_topic_name("0050_subscribe_adds_2", 1)), in main_0050_subscribe_adds() 52 rd_strdup(test_mk_topic_name("0050_subscribe_adds_3", 1)), in main_0050_subscribe_adds()
|
H A D | 0051-assign_adds.c | 50 rd_strdup(test_mk_topic_name("0051_assign_adds_1", 1)), in main_0051_assign_adds() 51 rd_strdup(test_mk_topic_name("0051_assign_adds_2", 1)), in main_0051_assign_adds() 52 rd_strdup(test_mk_topic_name("0051_assign_adds_3", 1)), in main_0051_assign_adds()
|
H A D | 0045-subscribe_update.c | 142 char *topic_a = rd_strdup(test_mk_topic_name("topic_a", 1)); in do_test_non_exist_and_partchange() 200 char *base_topic = rd_strdup(test_mk_topic_name("topic", 1)); in do_test_regex() 277 char *topic_f = rd_strdup(test_mk_topic_name("topic_f", 1)); in do_test_topic_remove() 278 char *topic_g = rd_strdup(test_mk_topic_name("topic_g", 1)); in do_test_topic_remove()
|
H A D | 0033-regex_subscribe.c | 260 test_mk_topic_name("regex_subscribe_TOPIC_0001_UNO", 0), in do_test() 264 test_mk_topic_name("regex_subscribe_topic_0002_dup", 0), in do_test() 268 test_mk_topic_name("regex_subscribe_TOOTHPIC_0003_3", 0), in do_test() 275 test_mk_topic_name("regex_subscribe_NONEXISTENT_0004_IV#!", in do_test()
|
H A D | 0011-produce_batch.c | 101 rkt = rd_kafka_topic_new(rk, test_mk_topic_name("0011", 0), in test_single_partition() 221 rkt = rd_kafka_topic_new(rk, test_mk_topic_name("0011", 0), in test_partitioner() 337 topic_name = test_mk_topic_name("0011_per_message_flag", 1); in test_per_message_partition_flag() 471 rkt = rd_kafka_topic_new(rk, test_mk_topic_name("0011", 0), in test_message_partitioner_wo_per_message_flag()
|
H A D | 0002-unkpart.c | 91 rkt = rd_kafka_topic_new(rk, test_mk_topic_name("0002", 0), in do_test_unkpart() 174 const char *topic = test_mk_topic_name("0002_unkpart_tmout", 0); in do_test_unkpart_timeout_nobroker()
|
H A D | 0081-admin.c | 86 char *topic = rd_strdup(test_mk_topic_name(__FUNCTION__, 1)); in do_test_CreateTopics() 323 char *topic = rd_strdup(test_mk_topic_name(__FUNCTION__, 1)); in do_test_DeleteTopics() 520 char *topic = rd_strdup(test_mk_topic_name(__FUNCTION__, 1)); in do_test_CreatePartitions() 734 rd_strdupa(&topics[i], test_mk_topic_name(__FUNCTION__, 1)); in do_test_AlterConfigs() 925 rd_strdupa(&topics[0], test_mk_topic_name("DescribeConfigs_exist", 1)); in do_test_DescribeConfigs() 928 test_mk_topic_name("DescribeConfigs_notexist", 1)); in do_test_DescribeConfigs() 1115 topic = rd_kafka_NewTopic_new(test_mk_topic_name(__FUNCTION__, 1), in do_test_unclean_destroy()
|
H A D | 0103-transactions.c | 96 const char *topic = test_mk_topic_name("0103_transactions", 1); in do_test_basic_producer_txn() 289 rd_strdup(test_mk_topic_name("0103-transactions-input", 1)); in do_test_consumer_producer_txn() 291 rd_strdup(test_mk_topic_name("0103-transactions-output", 1)); in do_test_consumer_producer_txn() 511 const char *topic = test_mk_topic_name("0103-test_misuse_txn", 1); in do_test_misuse_txn() 670 const char *topic = test_mk_topic_name("0103_fenced_txn", 1); in do_test_fenced_txn()
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
H A D | 0050-subscribe_adds.c | 50 rd_strdup(test_mk_topic_name("0050_subscribe_adds_1", 1)), 51 rd_strdup(test_mk_topic_name("0050_subscribe_adds_2", 1)), 52 rd_strdup(test_mk_topic_name("0050_subscribe_adds_3", 1)),
|
H A D | 0051-assign_adds.c | 50 rd_strdup(test_mk_topic_name("0051_assign_adds_1", 1)), in main_0051_assign_adds() 51 rd_strdup(test_mk_topic_name("0051_assign_adds_2", 1)), in main_0051_assign_adds() 52 rd_strdup(test_mk_topic_name("0051_assign_adds_3", 1)), in main_0051_assign_adds()
|
H A D | 0045-subscribe_update.c | 142 char *topic_a = rd_strdup(test_mk_topic_name("topic_a", 1)); 200 char *base_topic = rd_strdup(test_mk_topic_name("topic", 1)); 272 char *topic_f = rd_strdup(test_mk_topic_name("topic_f", 1)); 273 char *topic_g = rd_strdup(test_mk_topic_name("topic_g", 1));
|
H A D | 0011-produce_batch.c | 101 rkt = rd_kafka_topic_new(rk, test_mk_topic_name("0011", 0), in test_single_partition() 221 rkt = rd_kafka_topic_new(rk, test_mk_topic_name("0011", 0), in test_partitioner() 337 topic_name = test_mk_topic_name("0011_per_message_flag", 1); in test_per_message_partition_flag() 472 rkt = rd_kafka_topic_new(rk, test_mk_topic_name("0011", 0), in test_message_partitioner_wo_per_message_flag()
|
H A D | 0103-transactions.c | 98 const char *topic = test_mk_topic_name("0103_transactions", 1); in do_test_basic_producer_txn() 309 rd_strdup(test_mk_topic_name("0103-transactions-input", 1)); in do_test_consumer_producer_txn() 311 rd_strdup(test_mk_topic_name("0103-transactions-output", 1)); in do_test_consumer_producer_txn() 532 const char *topic = test_mk_topic_name("0103-test_misuse_txn", 1); in do_test_misuse_txn() 699 const char *topic = test_mk_topic_name("0103_fenced_txn", 1); in do_test_fenced_txn() 789 const char *topic = test_mk_topic_name("0103_fatal_idempo", 1); in do_test_fatal_idempo_error_without_kip360() 970 const char *topic = test_mk_topic_name("0103_empty_txn", 1); in do_test_empty_txn()
|
H A D | 0033-regex_subscribe.c | 297 test_mk_topic_name("regex_subscribe_TOPIC_0001_UNO", 0), in do_test() 301 test_mk_topic_name("regex_subscribe_topic_0002_dup", 0), in do_test() 305 test_mk_topic_name("regex_subscribe_TOOTHPIC_0003_3", 0), in do_test() 312 test_mk_topic_name("regex_subscribe_NONEXISTENT_0004_IV#!", in do_test()
|
H A D | 0002-unkpart.c | 91 rkt = rd_kafka_topic_new(rk, test_mk_topic_name("0002", 0), in do_test_unkpart() 174 const char *topic = test_mk_topic_name("0002_unkpart_tmout", 0); in do_test_unkpart_timeout_nobroker()
|
H A D | 0081-admin.c | 88 char *topic = rd_strdup(test_mk_topic_name(__FUNCTION__, 1)); in do_test_CreateTopics() 333 char *topic = rd_strdup(test_mk_topic_name(__FUNCTION__, 1)); in do_test_DeleteTopics() 535 char *topic = rd_strdup(test_mk_topic_name(__FUNCTION__, 1)); in do_test_CreatePartitions() 754 rd_strdupa(&topics[i], test_mk_topic_name(__FUNCTION__, 1)); in do_test_AlterConfigs() 955 rd_strdupa(&topics[0], test_mk_topic_name("DescribeConfigs_exist", 1)); in do_test_DescribeConfigs() 958 test_mk_topic_name("DescribeConfigs_notexist", 1)); in do_test_DescribeConfigs() 1148 topic = rd_kafka_NewTopic_new(test_mk_topic_name(__FUNCTION__, 1), in do_test_unclean_destroy() 1219 topic = rd_strdup(test_mk_topic_name(pfx, 1)); in do_test_DeleteRecords() 1508 topic = rd_strdup(test_mk_topic_name(__FUNCTION__, 1)); in do_test_DeleteGroups() 1526 char *group = rd_strdup(test_mk_topic_name(__FUNCTION__, 1)); in do_test_DeleteGroups() [all …]
|