| /dports/net/librdkafka/librdkafka-1.8.2/tests/ |
| H A D | 0018-cgrp_term.c | 94 if (!rk_c[i]) in consume_all()
129 rd_kafka_t *rk_p, *rk_c[_CONS_CNT]; in main_0018_cgrp_term() local
196 consume_all(rk_c, _CONS_CNT, msg_cnt, in main_0018_cgrp_term()
202 rd_kafka_name(rk_c[0])); in main_0018_cgrp_term()
203 err = rd_kafka_consumer_close(rk_c[0]); in main_0018_cgrp_term()
206 rd_kafka_destroy(rk_c[0]); in main_0018_cgrp_term()
207 rk_c[0] = NULL; in main_0018_cgrp_term()
226 if (!rk_c[i]) in main_0018_cgrp_term()
252 err = rd_kafka_consumer_close(rk_c[i]); in main_0018_cgrp_term()
258 rd_kafka_destroy(rk_c[i]); in main_0018_cgrp_term()
[all …]
|
| H A D | 0056-balanced_group_mt.c | 189 static void get_assignment (rd_kafka_t *rk_c) { in get_assignment() argument
200 rd_kafka_t *rk_p, *rk_c; in main_0056_balanced_group_mt() local
247 rk_c = test_create_consumer( in main_0056_balanced_group_mt()
251 test_consumer_subscribe(rk_c, topic); in main_0056_balanced_group_mt()
257 get_assignment(rk_c); in main_0056_balanced_group_mt()
270 err = rd_kafka_subscription(rk_c, &sub); in main_0056_balanced_group_mt()
281 err = rd_kafka_unsubscribe(rk_c); in main_0056_balanced_group_mt()
285 TEST_SAY("Closing %s\n", rd_kafka_name(rk_c)); in main_0056_balanced_group_mt()
287 err = rd_kafka_consumer_close(rk_c); in main_0056_balanced_group_mt()
291 rd_kafka_destroy(rk_c); in main_0056_balanced_group_mt()
[all …]
|
| H A D | xxxx-assign_partition.c | 43 rd_kafka_t *rk_p, *rk_c; in main_0016_assign_partition() local
76 rk_c = test_create_consumer(topic/*group_id*/, NULL, in main_0016_assign_partition()
85 test_consumer_assign("assign.partition", rk_c, partitions); in main_0016_assign_partition()
88 test_consumer_poll("verify.all", rk_c, testid, partition_cnt, in main_0016_assign_partition()
92 test_consumer_unassign("unassign.partitions", rk_c); in main_0016_assign_partition()
98 rd_kafka_topic_t *rkt_c = rd_kafka_topic_new(rk_c, topic, NULL); in main_0016_assign_partition()
117 test_consumer_close(rk_c); in main_0016_assign_partition()
119 rd_kafka_destroy(rk_c); in main_0016_assign_partition()
|
| H A D | 0028-long_topicnames.c | 47 rd_kafka_t *rk_c; in main_0028_long_topicnames() local
62 rk_c = test_create_consumer(topic, NULL, NULL, NULL); in main_0028_long_topicnames()
65 test_create_topic(rk_c, topic, 1, 1); in main_0028_long_topicnames()
67 test_consumer_subscribe(rk_c, topic); in main_0028_long_topicnames()
68 test_consumer_poll_no_msgs("consume.nomsgs", rk_c, 0, 5000); in main_0028_long_topicnames()
69 test_consumer_close(rk_c); in main_0028_long_topicnames()
|
| H A D | 0019-list_groups.c | 151 rd_kafka_t *rk, *rk_c[_CONS_CNT]; in main_0019_list_groups() local
182 rk_c[i] = test_create_consumer(groups[i], in main_0019_list_groups()
185 err = rd_kafka_poll_set_consumer(rk_c[i]); in main_0019_list_groups()
190 err = rd_kafka_subscribe(rk_c[i], topics); in main_0019_list_groups()
224 if (!rk_c[i]) in main_0019_list_groups()
227 TEST_SAY("Closing %s\n", rd_kafka_name(rk_c[i])); in main_0019_list_groups()
229 err = rd_kafka_consumer_close(rk_c[i]); in main_0019_list_groups()
235 rd_kafka_destroy(rk_c[i]); in main_0019_list_groups()
236 rk_c[i] = NULL; in main_0019_list_groups()
|
| H A D | 0083-cb_event.c | 80 rd_kafka_t *rk_p, *rk_c; in main_0083_cb_event() local
116 rk_c = test_create_consumer(topic, NULL, conf, tconf); in main_0083_cb_event()
118 queue = rd_kafka_queue_get_consumer(rk_c); in main_0083_cb_event()
120 test_consumer_subscribe(rk_c, topic); in main_0083_cb_event()
153 … rd_kafka_assign(rk_c, rd_kafka_event_topic_partition_list(rkev)); in main_0083_cb_event()
156 rd_kafka_assign(rk_c, NULL); in main_0083_cb_event()
208 rd_kafka_consumer_close(rk_c); in main_0083_cb_event()
209 rd_kafka_destroy(rk_c); in main_0083_cb_event()
|
| H A D | 0040-io_event.c | 54 rd_kafka_t *rk_p, *rk_c; in main_0040_io_event() local
92 rk_c = test_create_consumer(topic, NULL, conf, tconf); in main_0040_io_event()
94 queue = rd_kafka_queue_get_consumer(rk_c); in main_0040_io_event()
96 test_consumer_subscribe(rk_c, topic); in main_0040_io_event()
169 rd_kafka_assign(rk_c, rd_kafka_event_topic_partition_list(rkev)); in main_0040_io_event()
172 rd_kafka_assign(rk_c, NULL); in main_0040_io_event()
225 rd_kafka_consumer_close(rk_c); in main_0040_io_event()
226 rd_kafka_destroy(rk_c); in main_0040_io_event()
|
| H A D | 0017-compression.c | 42 rd_kafka_t *rk_p, *rk_c; in main_0017_compression() local
107 rk_c = test_create_consumer(NULL, NULL, conf, NULL); in main_0017_compression()
110 rd_kafka_topic_t *rkt_c = rd_kafka_topic_new(rk_c, in main_0017_compression()
136 rd_kafka_destroy(rk_c); in main_0017_compression()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
| H A D | 0018-cgrp_term.c | 94 if (!rk_c[i]) in consume_all()
129 rd_kafka_t *rk_p, *rk_c[_CONS_CNT]; in main_0018_cgrp_term() local
196 consume_all(rk_c, _CONS_CNT, msg_cnt, in main_0018_cgrp_term()
202 rd_kafka_name(rk_c[0])); in main_0018_cgrp_term()
203 err = rd_kafka_consumer_close(rk_c[0]); in main_0018_cgrp_term()
206 rd_kafka_destroy(rk_c[0]); in main_0018_cgrp_term()
207 rk_c[0] = NULL; in main_0018_cgrp_term()
226 if (!rk_c[i]) in main_0018_cgrp_term()
252 err = rd_kafka_consumer_close(rk_c[i]); in main_0018_cgrp_term()
258 rd_kafka_destroy(rk_c[i]); in main_0018_cgrp_term()
[all …]
|
| H A D | 0056-balanced_group_mt.c | 189 static void get_assignment (rd_kafka_t *rk_c) { in get_assignment() argument
200 rd_kafka_t *rk_p, *rk_c; in main_0056_balanced_group_mt() local
247 rk_c = test_create_consumer( in main_0056_balanced_group_mt()
251 test_consumer_subscribe(rk_c, topic); in main_0056_balanced_group_mt()
257 get_assignment(rk_c); in main_0056_balanced_group_mt()
270 err = rd_kafka_subscription(rk_c, &sub); in main_0056_balanced_group_mt()
281 err = rd_kafka_unsubscribe(rk_c); in main_0056_balanced_group_mt()
285 TEST_SAY("Closing %s\n", rd_kafka_name(rk_c)); in main_0056_balanced_group_mt()
287 err = rd_kafka_consumer_close(rk_c); in main_0056_balanced_group_mt()
291 rd_kafka_destroy(rk_c); in main_0056_balanced_group_mt()
[all …]
|
| H A D | xxxx-assign_partition.c | 43 rd_kafka_t *rk_p, *rk_c; in main_0016_assign_partition() local
76 rk_c = test_create_consumer(topic/*group_id*/, NULL, in main_0016_assign_partition()
85 test_consumer_assign("assign.partition", rk_c, partitions); in main_0016_assign_partition()
88 test_consumer_poll("verify.all", rk_c, testid, partition_cnt, in main_0016_assign_partition()
92 test_consumer_unassign("unassign.partitions", rk_c); in main_0016_assign_partition()
98 rd_kafka_topic_t *rkt_c = rd_kafka_topic_new(rk_c, topic, NULL); in main_0016_assign_partition()
117 test_consumer_close(rk_c); in main_0016_assign_partition()
119 rd_kafka_destroy(rk_c); in main_0016_assign_partition()
|
| H A D | 0028-long_topicnames.c | 47 rd_kafka_t *rk_c; in main_0028_long_topicnames() local
62 rk_c = test_create_consumer(topic, NULL, NULL, NULL); in main_0028_long_topicnames()
65 test_create_topic(rk_c, topic, 1, 1); in main_0028_long_topicnames()
67 test_consumer_subscribe(rk_c, topic); in main_0028_long_topicnames()
68 test_consumer_poll_no_msgs("consume.nomsgs", rk_c, 0, 5000); in main_0028_long_topicnames()
69 test_consumer_close(rk_c); in main_0028_long_topicnames()
|
| H A D | 0019-list_groups.c | 151 rd_kafka_t *rk, *rk_c[_CONS_CNT]; in main_0019_list_groups() local
182 rk_c[i] = test_create_consumer(groups[i], in main_0019_list_groups()
185 err = rd_kafka_poll_set_consumer(rk_c[i]); in main_0019_list_groups()
190 err = rd_kafka_subscribe(rk_c[i], topics); in main_0019_list_groups()
224 if (!rk_c[i]) in main_0019_list_groups()
227 TEST_SAY("Closing %s\n", rd_kafka_name(rk_c[i])); in main_0019_list_groups()
229 err = rd_kafka_consumer_close(rk_c[i]); in main_0019_list_groups()
235 rd_kafka_destroy(rk_c[i]); in main_0019_list_groups()
236 rk_c[i] = NULL; in main_0019_list_groups()
|
| H A D | 0083-cb_event.c | 80 rd_kafka_t *rk_p, *rk_c; in main_0083_cb_event() local
116 rk_c = test_create_consumer(topic, NULL, conf, tconf); in main_0083_cb_event()
118 queue = rd_kafka_queue_get_consumer(rk_c); in main_0083_cb_event()
120 test_consumer_subscribe(rk_c, topic); in main_0083_cb_event()
153 … rd_kafka_assign(rk_c, rd_kafka_event_topic_partition_list(rkev)); in main_0083_cb_event()
156 rd_kafka_assign(rk_c, NULL); in main_0083_cb_event()
208 rd_kafka_consumer_close(rk_c); in main_0083_cb_event()
209 rd_kafka_destroy(rk_c); in main_0083_cb_event()
|
| H A D | 0040-io_event.c | 54 rd_kafka_t *rk_p, *rk_c; in main_0040_io_event() local
92 rk_c = test_create_consumer(topic, NULL, conf, tconf); in main_0040_io_event()
94 queue = rd_kafka_queue_get_consumer(rk_c); in main_0040_io_event()
96 test_consumer_subscribe(rk_c, topic); in main_0040_io_event()
171 rd_kafka_assign(rk_c, rd_kafka_event_topic_partition_list(rkev)); in main_0040_io_event()
174 rd_kafka_assign(rk_c, NULL); in main_0040_io_event()
227 rd_kafka_consumer_close(rk_c); in main_0040_io_event()
228 rd_kafka_destroy(rk_c); in main_0040_io_event()
|
| H A D | 0015-offset_seeks.c | 40 rd_kafka_t *rk_p, *rk_c; in main_0015_offsets_seek() local
64 rk_c = test_create_consumer(NULL, NULL, NULL, NULL); in main_0015_offsets_seek()
65 rkt_c = test_create_consumer_topic(rk_c, topic); in main_0015_offsets_seek()
99 rd_kafka_destroy(rk_c); in main_0015_offsets_seek()
|
| H A D | 0017-compression.c | 42 rd_kafka_t *rk_p, *rk_c; in main_0017_compression() local
107 rk_c = test_create_consumer(NULL, NULL, conf, NULL); in main_0017_compression()
110 rd_kafka_topic_t *rkt_c = rd_kafka_topic_new(rk_c, in main_0017_compression()
136 rd_kafka_destroy(rk_c); in main_0017_compression()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
| H A D | 0018-cgrp_term.c | 94 if (!rk_c[i]) in consume_all()
129 rd_kafka_t *rk_p, *rk_c[_CONS_CNT]; in main_0018_cgrp_term() local
196 consume_all(rk_c, _CONS_CNT, msg_cnt, in main_0018_cgrp_term()
202 rd_kafka_name(rk_c[0])); in main_0018_cgrp_term()
203 err = rd_kafka_consumer_close(rk_c[0]); in main_0018_cgrp_term()
206 rd_kafka_destroy(rk_c[0]); in main_0018_cgrp_term()
207 rk_c[0] = NULL; in main_0018_cgrp_term()
226 if (!rk_c[i]) in main_0018_cgrp_term()
252 err = rd_kafka_consumer_close(rk_c[i]); in main_0018_cgrp_term()
258 rd_kafka_destroy(rk_c[i]); in main_0018_cgrp_term()
[all …]
|
| H A D | 0056-balanced_group_mt.c | 189 static void get_assignment (rd_kafka_t *rk_c) { in get_assignment() argument
200 rd_kafka_t *rk_p, *rk_c; in main_0056_balanced_group_mt() local
247 rk_c = test_create_consumer( in main_0056_balanced_group_mt()
251 test_consumer_subscribe(rk_c, topic); in main_0056_balanced_group_mt()
257 get_assignment(rk_c); in main_0056_balanced_group_mt()
270 err = rd_kafka_subscription(rk_c, &sub); in main_0056_balanced_group_mt()
281 err = rd_kafka_unsubscribe(rk_c); in main_0056_balanced_group_mt()
285 TEST_SAY("Closing %s\n", rd_kafka_name(rk_c)); in main_0056_balanced_group_mt()
287 err = rd_kafka_consumer_close(rk_c); in main_0056_balanced_group_mt()
291 rd_kafka_destroy(rk_c); in main_0056_balanced_group_mt()
[all …]
|
| H A D | xxxx-assign_partition.c | 43 rd_kafka_t *rk_p, *rk_c; in main_0016_assign_partition() local
76 rk_c = test_create_consumer(topic/*group_id*/, NULL, in main_0016_assign_partition()
85 test_consumer_assign("assign.partition", rk_c, partitions); in main_0016_assign_partition()
88 test_consumer_poll("verify.all", rk_c, testid, partition_cnt, in main_0016_assign_partition()
92 test_consumer_unassign("unassign.partitions", rk_c); in main_0016_assign_partition()
98 rd_kafka_topic_t *rkt_c = rd_kafka_topic_new(rk_c, topic, NULL); in main_0016_assign_partition()
117 test_consumer_close(rk_c); in main_0016_assign_partition()
119 rd_kafka_destroy(rk_c); in main_0016_assign_partition()
|
| H A D | 0028-long_topicnames.c | 47 rd_kafka_t *rk_c; in main_0028_long_topicnames() local
62 rk_c = test_create_consumer(topic, NULL, NULL, NULL); in main_0028_long_topicnames()
65 test_create_topic(rk_c, topic, 1, 1); in main_0028_long_topicnames()
67 test_consumer_subscribe(rk_c, topic); in main_0028_long_topicnames()
68 test_consumer_poll_no_msgs("consume.nomsgs", rk_c, 0, 5000); in main_0028_long_topicnames()
69 test_consumer_close(rk_c); in main_0028_long_topicnames()
|
| H A D | 0019-list_groups.c | 151 rd_kafka_t *rk, *rk_c[_CONS_CNT]; in main_0019_list_groups() local
182 rk_c[i] = test_create_consumer(groups[i], in main_0019_list_groups()
185 err = rd_kafka_poll_set_consumer(rk_c[i]); in main_0019_list_groups()
190 err = rd_kafka_subscribe(rk_c[i], topics); in main_0019_list_groups()
224 if (!rk_c[i]) in main_0019_list_groups()
227 TEST_SAY("Closing %s\n", rd_kafka_name(rk_c[i])); in main_0019_list_groups()
229 err = rd_kafka_consumer_close(rk_c[i]); in main_0019_list_groups()
235 rd_kafka_destroy(rk_c[i]); in main_0019_list_groups()
236 rk_c[i] = NULL; in main_0019_list_groups()
|
| H A D | 0083-cb_event.c | 80 rd_kafka_t *rk_p, *rk_c; in main_0083_cb_event() local
116 rk_c = test_create_consumer(topic, NULL, conf, tconf); in main_0083_cb_event()
118 queue = rd_kafka_queue_get_consumer(rk_c); in main_0083_cb_event()
120 test_consumer_subscribe(rk_c, topic); in main_0083_cb_event()
153 … rd_kafka_assign(rk_c, rd_kafka_event_topic_partition_list(rkev)); in main_0083_cb_event()
156 rd_kafka_assign(rk_c, NULL); in main_0083_cb_event()
208 rd_kafka_consumer_close(rk_c); in main_0083_cb_event()
209 rd_kafka_destroy(rk_c); in main_0083_cb_event()
|
| H A D | 0040-io_event.c | 54 rd_kafka_t *rk_p, *rk_c; in main_0040_io_event() local
92 rk_c = test_create_consumer(topic, NULL, conf, tconf); in main_0040_io_event()
94 queue = rd_kafka_queue_get_consumer(rk_c); in main_0040_io_event()
96 test_consumer_subscribe(rk_c, topic); in main_0040_io_event()
169 rd_kafka_assign(rk_c, rd_kafka_event_topic_partition_list(rkev)); in main_0040_io_event()
172 rd_kafka_assign(rk_c, NULL); in main_0040_io_event()
225 rd_kafka_consumer_close(rk_c); in main_0040_io_event()
226 rd_kafka_destroy(rk_c); in main_0040_io_event()
|
| H A D | 0017-compression.c | 42 rd_kafka_t *rk_p, *rk_c; in main_0017_compression() local
107 rk_c = test_create_consumer(NULL, NULL, conf, NULL); in main_0017_compression()
110 rd_kafka_topic_t *rkt_c = rd_kafka_topic_new(rk_c, in main_0017_compression()
136 rd_kafka_destroy(rk_c); in main_0017_compression()
|