/dports/net/librdkafka/librdkafka-1.8.2/tests/ |
H A D | 0099-commit_metadata.c | 97 static void offset_commit_cb (rd_kafka_t *rk, in offset_commit_cb() function 118 rd_kafka_conf_set_offset_commit_cb(conf, offset_commit_cb); in commit_metadata()
|
H A D | 0060-op_prio.cpp | 54 void offset_commit_cb (RdKafka::ErrorCode err, in offset_commit_cb() function in MyCbs
|
H A D | 0030-offset_commit.c | 50 static void offset_commit_cb (rd_kafka_t *rk, rd_kafka_resp_err_t err, in offset_commit_cb() function 121 rd_kafka_conf_set_offset_commit_cb(conf, offset_commit_cb); in do_offset_test()
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
H A D | 0099-commit_metadata.c | 97 static void offset_commit_cb (rd_kafka_t *rk, in offset_commit_cb() function 118 rd_kafka_conf_set_offset_commit_cb(conf, offset_commit_cb); in commit_metadata()
|
H A D | 0060-op_prio.cpp | 54 void offset_commit_cb (RdKafka::ErrorCode err, in offset_commit_cb() function in MyCbs
|
H A D | 0030-offset_commit.c | 50 static void offset_commit_cb (rd_kafka_t *rk, rd_kafka_resp_err_t err, in offset_commit_cb() function 119 rd_kafka_conf_set_offset_commit_cb(conf, offset_commit_cb); in do_offset_test()
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
H A D | 0099-commit_metadata.c | 97 static void offset_commit_cb (rd_kafka_t *rk, in offset_commit_cb() function 118 rd_kafka_conf_set_offset_commit_cb(conf, offset_commit_cb); in commit_metadata()
|
H A D | 0060-op_prio.cpp | 54 void offset_commit_cb (RdKafka::ErrorCode err, in offset_commit_cb() function in MyCbs
|
H A D | 0030-offset_commit.c | 50 static void offset_commit_cb (rd_kafka_t *rk, rd_kafka_resp_err_t err, in offset_commit_cb() function 121 rd_kafka_conf_set_offset_commit_cb(conf, offset_commit_cb); in do_offset_test()
|
/dports/net/pecl-rdkafka/rdkafka-4.0.4/tests/ |
H A D | conf_callbacks.phpt | 19 var_dump(isset($dump["offset_commit_cb"]));
|
/dports/net/librdkafka/librdkafka-1.8.2/src-cpp/ |
H A D | rdkafkacpp_int.h | 654 OffsetCommitCb *offset_commit_cb, in set() argument 666 offset_commit_cb_ = offset_commit_cb; in set() 824 Conf::ConfResult get(OffsetCommitCb *&offset_commit_cb) const { in get() argument 827 offset_commit_cb = this->offset_commit_cb_; in get() 1191 ErrorCode commitSync (OffsetCommitCb *offset_commit_cb) { in commitSync() argument 1195 offset_commit_cb)); in commitSync() 1199 OffsetCommitCb *offset_commit_cb) { in commitSync() argument 1205 offset_commit_cb); in commitSync()
|
H A D | rdkafkacpp.h | 1044 virtual void offset_commit_cb(RdKafka::ErrorCode err, 1269 OffsetCommitCb *offset_commit_cb, 1375 virtual Conf::ConfResult get(OffsetCommitCb *&offset_commit_cb) const = 0; 2662 virtual ErrorCode commitSync (OffsetCommitCb *offset_commit_cb) = 0; 2675 OffsetCommitCb *offset_commit_cb) = 0;
|
H A D | HandleImpl.cpp | 248 cb->offset_commit_cb(static_cast<RdKafka::ErrorCode>(err), offsets); in offset_commit_cb_trampoline0()
|
/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 | 641 OffsetCommitCb *offset_commit_cb, in set() argument 653 offset_commit_cb_ = offset_commit_cb; in set() 799 Conf::ConfResult get(OffsetCommitCb *&offset_commit_cb) const { in get() argument 802 offset_commit_cb = this->offset_commit_cb_; in get() 1151 ErrorCode commitSync (OffsetCommitCb *offset_commit_cb) { in commitSync() argument 1155 offset_commit_cb)); in commitSync() 1159 OffsetCommitCb *offset_commit_cb) { in commitSync() argument 1165 offset_commit_cb); in commitSync()
|
H A D | rdkafkacpp.h | 949 virtual void offset_commit_cb(RdKafka::ErrorCode err, 1174 OffsetCommitCb *offset_commit_cb, 1277 virtual Conf::ConfResult get(OffsetCommitCb *&offset_commit_cb) const = 0; 2508 virtual ErrorCode commitSync (OffsetCommitCb *offset_commit_cb) = 0; 2521 OffsetCommitCb *offset_commit_cb) = 0;
|
H A D | HandleImpl.cpp | 246 cb->offset_commit_cb(static_cast<RdKafka::ErrorCode>(err), offsets); in offset_commit_cb_trampoline0()
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src-cpp/ |
H A D | rdkafkacpp_int.h | 654 OffsetCommitCb *offset_commit_cb, in set() argument 666 offset_commit_cb_ = offset_commit_cb; in set() 824 Conf::ConfResult get(OffsetCommitCb *&offset_commit_cb) const { in get() argument 827 offset_commit_cb = this->offset_commit_cb_; in get() 1191 ErrorCode commitSync (OffsetCommitCb *offset_commit_cb) { in commitSync() argument 1195 offset_commit_cb)); in commitSync() 1199 OffsetCommitCb *offset_commit_cb) { in commitSync() argument 1205 offset_commit_cb); in commitSync()
|
H A D | rdkafkacpp.h | 1044 virtual void offset_commit_cb(RdKafka::ErrorCode err, 1269 OffsetCommitCb *offset_commit_cb, 1372 virtual Conf::ConfResult get(OffsetCommitCb *&offset_commit_cb) const = 0; 2659 virtual ErrorCode commitSync (OffsetCommitCb *offset_commit_cb) = 0; 2672 OffsetCommitCb *offset_commit_cb) = 0;
|
H A D | HandleImpl.cpp | 248 cb->offset_commit_cb(static_cast<RdKafka::ErrorCode>(err), offsets); in offset_commit_cb_trampoline0()
|
/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 | 353 void (*offset_commit_cb) (rd_kafka_t *rk, member
|
/dports/net/librdkafka/librdkafka-1.8.2/src/ |
H A D | rdkafka_conf.h | 363 void (*offset_commit_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 | 362 void (*offset_commit_cb) (rd_kafka_t *rk,
|
/dports/net/librdkafka/librdkafka-1.8.2/examples/ |
H A D | rdkafka_performance.c | 151 static void offset_commit_cb (rd_kafka_t *rk, rd_kafka_resp_err_t err, in offset_commit_cb() function 855 rd_kafka_conf_set_offset_commit_cb(conf, offset_commit_cb); in main()
|
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/examples/ |
H A D | rdkafka_performance.c | 151 static void offset_commit_cb (rd_kafka_t *rk, rd_kafka_resp_err_t err, in offset_commit_cb() function 831 rd_kafka_conf_set_offset_commit_cb(conf, offset_commit_cb); in main()
|
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/examples/ |
H A D | rdkafka_performance.c | 151 static void offset_commit_cb (rd_kafka_t *rk, rd_kafka_resp_err_t err, in offset_commit_cb() function 855 rd_kafka_conf_set_offset_commit_cb(conf, offset_commit_cb); in main()
|