| /dports/net/pecl-rdkafka/rdkafka-4.0.4/tests/ |
| H A D | conf_callbacks.phpt | 24 var_dump(isset($dump["rebalance_cb"]));
|
| /dports/net/librdkafka/librdkafka-1.8.2/tests/ |
| H A D | 0102-static_group_rebalance.c | 98 static void rebalance_cb (rd_kafka_t *rk, in rebalance_cb() function
175 c[0].rk = test_create_consumer(topic, rebalance_cb, in do_test_static_group_rebalance()
180 c[1].rk = test_create_consumer(topic, rebalance_cb, in do_test_static_group_rebalance()
|
| H A D | 0026-consume_pause.c | 358 static void rebalance_cb (rd_kafka_t *rk, in rebalance_cb() function
418 rd_kafka_conf_set_rebalance_cb(conf, rebalance_cb); in consume_subscribe_assign_pause_resume()
|
| H A D | 0033-regex_subscribe.c | 116 static void rebalance_cb (rd_kafka_t *rk, rd_kafka_resp_err_t err, in rebalance_cb() function
329 rk = test_create_consumer(groupid, rebalance_cb, conf, NULL); in do_test()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
| H A D | 0102-static_group_rebalance.c | 95 static void rebalance_cb (rd_kafka_t *rk, in rebalance_cb() function
169 c[0].rk = test_create_consumer(topic, rebalance_cb, in do_test_static_group_rebalance()
174 c[1].rk = test_create_consumer(topic, rebalance_cb, in do_test_static_group_rebalance()
|
| H A D | 0026-consume_pause.c | 358 static void rebalance_cb (rd_kafka_t *rk, in rebalance_cb() function
418 rd_kafka_conf_set_rebalance_cb(conf, rebalance_cb); in consume_subscribe_assign_pause_resume()
|
| H A D | 0033-regex_subscribe.c | 116 static void rebalance_cb (rd_kafka_t *rk, rd_kafka_resp_err_t err, in rebalance_cb() function
291 rk = test_create_consumer(groupid, rebalance_cb, conf, NULL); in do_test()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
| H A D | 0102-static_group_rebalance.c | 98 static void rebalance_cb (rd_kafka_t *rk, in rebalance_cb() function
175 c[0].rk = test_create_consumer(topic, rebalance_cb, in do_test_static_group_rebalance()
180 c[1].rk = test_create_consumer(topic, rebalance_cb, in do_test_static_group_rebalance()
|
| H A D | 0026-consume_pause.c | 358 static void rebalance_cb (rd_kafka_t *rk,
418 rd_kafka_conf_set_rebalance_cb(conf, rebalance_cb);
|
| H A D | 0033-regex_subscribe.c | 116 static void rebalance_cb (rd_kafka_t *rk, rd_kafka_resp_err_t err, in rebalance_cb() function
329 rk = test_create_consumer(groupid, rebalance_cb, conf, NULL); in do_test()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/examples/ |
| H A D | rdkafka_complex_consumer_example.c | 191 static void rebalance_cb (rd_kafka_t *rk, in rebalance_cb() function
493 rd_kafka_conf_set_rebalance_cb(conf, rebalance_cb); in main()
|
| H A D | rdkafka_complex_consumer_example.cpp | 142 void rebalance_cb (RdKafka::KafkaConsumer *consumer, in rebalance_cb() function in ExampleRebalanceCb
|
| /dports/net/librdkafka/librdkafka-1.8.2/examples/ |
| H A D | rdkafka_complex_consumer_example.c | 191 static void rebalance_cb (rd_kafka_t *rk, in rebalance_cb() function
494 rd_kafka_conf_set_rebalance_cb(conf, rebalance_cb); in main()
|
| H A D | rdkafka_complex_consumer_example.cpp | 147 void rebalance_cb (RdKafka::KafkaConsumer *consumer, in rebalance_cb() function in ExampleRebalanceCb
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/examples/ |
| H A D | rdkafka_complex_consumer_example.c | 191 static void rebalance_cb (rd_kafka_t *rk, in rebalance_cb() function
494 rd_kafka_conf_set_rebalance_cb(conf, rebalance_cb); in main()
|
| H A D | rdkafka_complex_consumer_example.cpp | 147 void rebalance_cb (RdKafka::KafkaConsumer *consumer,
|
| /dports/net/librdkafka/librdkafka-1.8.2/src-cpp/ |
| H A D | rdkafkacpp_int.h | 636 Conf::ConfResult set (const std::string &name, RebalanceCb *rebalance_cb, in set() argument
648 rebalance_cb_ = rebalance_cb; in set()
817 Conf::ConfResult get(RebalanceCb *&rebalance_cb) const { in get() argument
820 rebalance_cb = this->rebalance_cb_; in get()
|
| H A D | rdkafkacpp.h | 1016 virtual void rebalance_cb (RdKafka::KafkaConsumer *consumer,
1264 RebalanceCb *rebalance_cb,
1370 virtual Conf::ConfResult get(RebalanceCb *&rebalance_cb) const = 0;
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src-cpp/ |
| H A D | rdkafkacpp_int.h | 623 Conf::ConfResult set (const std::string &name, RebalanceCb *rebalance_cb, in set() argument
635 rebalance_cb_ = rebalance_cb; in set()
792 Conf::ConfResult get(RebalanceCb *&rebalance_cb) const { in get() argument
795 rebalance_cb = this->rebalance_cb_; in get()
|
| H A D | rdkafkacpp.h | 921 virtual void rebalance_cb (RdKafka::KafkaConsumer *consumer,
1169 RebalanceCb *rebalance_cb,
1272 virtual Conf::ConfResult get(RebalanceCb *&rebalance_cb) const = 0;
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src-cpp/ |
| H A D | rdkafkacpp_int.h | 636 Conf::ConfResult set (const std::string &name, RebalanceCb *rebalance_cb, in set() argument
648 rebalance_cb_ = rebalance_cb; in set()
817 Conf::ConfResult get(RebalanceCb *&rebalance_cb) const { in get() argument
820 rebalance_cb = this->rebalance_cb_; in get()
|
| H A D | rdkafkacpp.h | 1016 virtual void rebalance_cb (RdKafka::KafkaConsumer *consumer,
1264 RebalanceCb *rebalance_cb,
1367 virtual Conf::ConfResult get(RebalanceCb *&rebalance_cb) const = 0;
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
| H A D | rdkafka_conf.h | 348 void (*rebalance_cb) (rd_kafka_t *rk, member
|
| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdkafka_conf.h | 358 void (*rebalance_cb) (rd_kafka_t *rk, member
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdkafka_conf.h | 357 void (*rebalance_cb) (rd_kafka_t *rk,
|