| /dports/net/librdkafka/librdkafka-1.8.2/tests/ |
| H A D | 0015-offset_seeks.c | 149 const char *topic = test_mk_topic_name("0015", 1); in main_0015_offsets_seek()
|
| H A D | 0083-cb_event.c | 101 topic = test_mk_topic_name(__FUNCTION__, 1); in main_0083_cb_event()
|
| H A D | 0084-destroy_flags.c | 182 const char *topic = test_mk_topic_name(__FUNCTION__, 1); in destroy_flags()
|
| H A D | 0107-topic_recreate.c | 184 const char *topic = test_mk_topic_name(__FUNCTION__, 1); in do_test_create_delete_create()
|
| H A D | 0052-msg_timestamps.c | 140 const char *topic = test_mk_topic_name( in test_timestamps()
|
| H A D | 0093-holb.c | 107 const char *topic = test_mk_topic_name("0093_holb_consumer", 1); in main_0093_holb_consumer()
|
| H A D | 0080-admin_ut.c | 109 const char *topic = test_mk_topic_name(__FUNCTION__, 1); in do_test_CreateTopics()
312 del_topics[i] = rd_kafka_DeleteTopic_new(test_mk_topic_name(__FUNCTION__, 1)); in do_test_DeleteTopics()
414 group_names[i] = rd_strdup(test_mk_topic_name(__FUNCTION__, 1)); in do_test_DeleteGroups()
533 topics[i] = rd_strdup(test_mk_topic_name(__FUNCTION__, 1)); in do_test_DeleteRecords()
|
| H A D | 0030-offset_commit.c | 482 const char *unk_topic = test_mk_topic_name(__FUNCTION__, 1); in do_nonexist_commit()
529 topic = rd_strdup(test_mk_topic_name(__FUNCTION__, 1)); in main_0030_offset_commit()
|
| H A D | 0102-static_group_rebalance.c | 151 const char *topic = test_mk_topic_name("0102_static_group_rebalance", in do_test_static_group_rebalance()
449 const char *topic = test_mk_topic_name("0102_static_group_rebalance", in do_test_fenced_member()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
| H A D | 0003-msgmaxsize.c | 107 rkt = rd_kafka_topic_new(rk, test_mk_topic_name("0003", 0), in main_0003_msgmaxsize()
|
| H A D | 0039-event.c | 105 rkt = rd_kafka_topic_new(rk, test_mk_topic_name("0005", 0), in main_0039_event_dr()
|
| H A D | 0083-cb_event.c | 101 topic = test_mk_topic_name(__FUNCTION__, 1); in main_0083_cb_event()
|
| H A D | 0084-destroy_flags.c | 182 const char *topic = test_mk_topic_name(__FUNCTION__, 1); in destroy_flags()
|
| H A D | testcpp.h | 97 return test_mk_topic_name(suffix.c_str(), in mk_topic_name()
|
| H A D | 0052-msg_timestamps.c | 140 const char *topic = test_mk_topic_name( in test_timestamps()
|
| H A D | 0107-topic_recreate.c | 184 const char *topic = test_mk_topic_name(__FUNCTION__, 1); in do_test_create_delete_create()
|
| H A D | 0093-holb.c | 107 const char *topic = test_mk_topic_name("0093_holb_consumer", 1); in main_0093_holb_consumer()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
| H A D | 0003-msgmaxsize.c | 107 rkt = rd_kafka_topic_new(rk, test_mk_topic_name("0003", 0),
|
| H A D | 0015-offset_seeks.c | 149 const char *topic = test_mk_topic_name("0015", 1); in main_0015_offsets_seek()
|
| H A D | 0083-cb_event.c | 101 topic = test_mk_topic_name(__FUNCTION__, 1); in main_0083_cb_event()
|
| H A D | 0084-destroy_flags.c | 182 const char *topic = test_mk_topic_name(__FUNCTION__, 1);
|
| H A D | 0052-msg_timestamps.c | 140 const char *topic = test_mk_topic_name( in test_timestamps()
|
| H A D | 0093-holb.c | 107 const char *topic = test_mk_topic_name("0093_holb_consumer", 1); in main_0093_holb_consumer()
|
| H A D | 0107-topic_recreate.c | 184 const char *topic = test_mk_topic_name(__FUNCTION__, 1); in do_test_create_delete_create()
|
| H A D | 0080-admin_ut.c | 109 const char *topic = test_mk_topic_name(__FUNCTION__, 1); in do_test_CreateTopics()
312 del_topics[i] = rd_kafka_DeleteTopic_new(test_mk_topic_name(__FUNCTION__, 1)); in do_test_DeleteTopics()
414 group_names[i] = rd_strdup(test_mk_topic_name(__FUNCTION__, 1)); in do_test_DeleteGroups()
533 topics[i] = rd_strdup(test_mk_topic_name(__FUNCTION__, 1)); in do_test_DeleteRecords()
|