| /dports/net/librdkafka/librdkafka-1.8.2/tests/ |
| H A D | 0118-commit_rebalance.c | 38 static void rebalance_cb (rd_kafka_t *rk, rd_kafka_resp_err_t err, in rebalance_cb() function
95 rd_kafka_conf_set_rebalance_cb(conf, rebalance_cb); in main_0118_commit_rebalance()
100 c1 = test_create_consumer(topic, rebalance_cb, in main_0118_commit_rebalance()
102 c2 = test_create_consumer(topic, rebalance_cb, conf, NULL); in main_0118_commit_rebalance()
|
| H A D | 0113-cooperative_rebalance.cpp | 161 if (rebalance_cb) { in make_consumer()
1232 FTestRebalanceCb rebalance_cb; in f_assign_call_cooperative() local
1238 while (!rebalance_cb.assigned) in f_assign_call_cooperative()
1306 GTestRebalanceCb rebalance_cb; in g_incremental_assign_call_eager() local
1312 while (!rebalance_cb.assigned) in g_incremental_assign_call_eager()
1341 DefaultRebalanceCb rebalance_cb; in h_delete_topic() local
1398 DefaultRebalanceCb rebalance_cb; in i_delete_topic_2() local
1495 DefaultRebalanceCb rebalance_cb; in k_add_partition() local
1528 if (rebalance_cb.assign_call_cnt != 2) in k_add_partition()
1860 DefaultRebalanceCb rebalance_cb; in o_java_interop() local
[all …]
|
| H A D | 0069-consumer_add_parts.c | 44 static void rebalance_cb (rd_kafka_t *rk, rd_kafka_resp_err_t err, in rebalance_cb() function
75 c1 = test_create_consumer(topic, rebalance_cb, NULL, NULL); in main_0069_consumer_add_parts()
76 c2 = test_create_consumer(topic, rebalance_cb, NULL, NULL); in main_0069_consumer_add_parts()
|
| H A D | 0029-assign_offset.c | 53 static void rebalance_cb (rd_kafka_t *rk, rd_kafka_resp_err_t err, in rebalance_cb() function
157 rk = test_create_consumer(topic, rebalance_cb, NULL, NULL); in main_0029_assign_offset()
178 rk = test_create_consumer(topic, rebalance_cb, NULL, NULL); in main_0029_assign_offset()
|
| H A D | 0093-holb.c | 79 static void rebalance_cb (rd_kafka_t *rk, in rebalance_cb() function
127 rd_kafka_conf_set_rebalance_cb(conf, rebalance_cb); in main_0093_holb_consumer()
|
| H A D | 0106-cgrp_sess_timeout.c | 44 static void rebalance_cb (rd_kafka_t *rk, in rebalance_cb() function
174 c = test_create_consumer(groupid, rebalance_cb, conf, NULL); in do_test_session_timeout()
|
| H A D | 0018-cgrp_term.c | 48 static void rebalance_cb (rd_kafka_t *rk, in rebalance_cb() function
173 rebalance_cb, NULL, in main_0018_cgrp_term()
|
| H A D | 0091-max_poll_interval_timeout.c | 89 static void rebalance_cb (rd_kafka_t *rk, in rebalance_cb() function
141 rd_kafka_conf_set_rebalance_cb(conf, rebalance_cb); in do_test_with_subscribe()
|
| H A D | 0056-balanced_group_mt.c | 133 static void rebalance_cb (rd_kafka_t *rk, rd_kafka_resp_err_t err, in rebalance_cb() function
248 topic /*group_id*/, rebalance_cb, in main_0056_balanced_group_mt()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
| H A D | 0118-commit_rebalance.c | 38 static void rebalance_cb (rd_kafka_t *rk, rd_kafka_resp_err_t err, in rebalance_cb() function
95 rd_kafka_conf_set_rebalance_cb(conf, rebalance_cb); in main_0118_commit_rebalance()
100 c1 = test_create_consumer(topic, rebalance_cb, in main_0118_commit_rebalance()
102 c2 = test_create_consumer(topic, rebalance_cb, conf, NULL); in main_0118_commit_rebalance()
|
| H A D | 0113-cooperative_rebalance.cpp | 161 if (rebalance_cb) {
1232 FTestRebalanceCb rebalance_cb;
1238 while (!rebalance_cb.assigned)
1306 GTestRebalanceCb rebalance_cb;
1312 while (!rebalance_cb.assigned)
1341 DefaultRebalanceCb rebalance_cb;
1398 DefaultRebalanceCb rebalance_cb;
1495 DefaultRebalanceCb rebalance_cb;
1528 if (rebalance_cb.assign_call_cnt != 2)
1860 DefaultRebalanceCb rebalance_cb;
[all …]
|
| H A D | 0069-consumer_add_parts.c | 44 static void rebalance_cb (rd_kafka_t *rk, rd_kafka_resp_err_t err,
75 c1 = test_create_consumer(topic, rebalance_cb, NULL, NULL);
76 c2 = test_create_consumer(topic, rebalance_cb, NULL, NULL);
|
| H A D | 0029-assign_offset.c | 53 static void rebalance_cb (rd_kafka_t *rk, rd_kafka_resp_err_t err,
157 rk = test_create_consumer(topic, rebalance_cb, NULL, NULL);
178 rk = test_create_consumer(topic, rebalance_cb, NULL, NULL);
|
| H A D | 0093-holb.c | 79 static void rebalance_cb (rd_kafka_t *rk, in rebalance_cb() function
127 rd_kafka_conf_set_rebalance_cb(conf, rebalance_cb); in main_0093_holb_consumer()
|
| H A D | 0106-cgrp_sess_timeout.c | 44 static void rebalance_cb (rd_kafka_t *rk, in rebalance_cb() function
174 c = test_create_consumer(groupid, rebalance_cb, conf, NULL); in do_test_session_timeout()
|
| H A D | 0018-cgrp_term.c | 48 static void rebalance_cb (rd_kafka_t *rk, in rebalance_cb() function
173 rebalance_cb, NULL, in main_0018_cgrp_term()
|
| H A D | 0091-max_poll_interval_timeout.c | 89 static void rebalance_cb (rd_kafka_t *rk, in rebalance_cb() function
141 rd_kafka_conf_set_rebalance_cb(conf, rebalance_cb); in do_test_with_subscribe()
|
| H A D | 0056-balanced_group_mt.c | 133 static void rebalance_cb (rd_kafka_t *rk, rd_kafka_resp_err_t err, in rebalance_cb() function
248 topic /*group_id*/, rebalance_cb, in main_0056_balanced_group_mt()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
| H A D | 0069-consumer_add_parts.c | 44 static void rebalance_cb (rd_kafka_t *rk, rd_kafka_resp_err_t err, in rebalance_cb() function
75 c1 = test_create_consumer(topic, rebalance_cb, NULL, NULL); in main_0069_consumer_add_parts()
76 c2 = test_create_consumer(topic, rebalance_cb, NULL, NULL); in main_0069_consumer_add_parts()
|
| H A D | 0029-assign_offset.c | 53 static void rebalance_cb (rd_kafka_t *rk, rd_kafka_resp_err_t err, in rebalance_cb() function
157 rk = test_create_consumer(topic, rebalance_cb, NULL, NULL); in main_0029_assign_offset()
178 rk = test_create_consumer(topic, rebalance_cb, NULL, NULL); in main_0029_assign_offset()
|
| H A D | 0106-cgrp_sess_timeout.c | 44 static void rebalance_cb (rd_kafka_t *rk, in rebalance_cb() function
169 c = test_create_consumer(groupid, rebalance_cb, conf, NULL); in do_test_session_timeout()
|
| H A D | 0093-holb.c | 79 static void rebalance_cb (rd_kafka_t *rk, in rebalance_cb() function
127 rd_kafka_conf_set_rebalance_cb(conf, rebalance_cb); in main_0093_holb_consumer()
|
| H A D | 0018-cgrp_term.c | 48 static void rebalance_cb (rd_kafka_t *rk, in rebalance_cb() function
173 rebalance_cb, NULL, in main_0018_cgrp_term()
|
| H A D | 0091-max_poll_interval_timeout.c | 89 static void rebalance_cb (rd_kafka_t *rk, in rebalance_cb() function
141 rd_kafka_conf_set_rebalance_cb(conf, rebalance_cb); in do_test_with_subscribe()
|
| H A D | 0056-balanced_group_mt.c | 133 static void rebalance_cb (rd_kafka_t *rk, rd_kafka_resp_err_t err, in rebalance_cb() function
248 topic /*group_id*/, rebalance_cb, in main_0056_balanced_group_mt()
|