| /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 …]
|