Home
last modified time | relevance | path

Searched refs:offset_commit_cb (Results 1 – 25 of 44) sorted by relevance

12

/dports/net/librdkafka/librdkafka-1.8.2/tests/
H A D0099-commit_metadata.c97 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 D0060-op_prio.cpp54 void offset_commit_cb (RdKafka::ErrorCode err, in offset_commit_cb() function in MyCbs
H A D0030-offset_commit.c50 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 D0099-commit_metadata.c97 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 D0060-op_prio.cpp54 void offset_commit_cb (RdKafka::ErrorCode err, in offset_commit_cb() function in MyCbs
H A D0030-offset_commit.c50 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 D0099-commit_metadata.c97 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 D0060-op_prio.cpp54 void offset_commit_cb (RdKafka::ErrorCode err, in offset_commit_cb() function in MyCbs
H A D0030-offset_commit.c50 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 Dconf_callbacks.phpt19 var_dump(isset($dump["offset_commit_cb"]));
/dports/net/librdkafka/librdkafka-1.8.2/src-cpp/
H A Drdkafkacpp_int.h654 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 Drdkafkacpp.h1044 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 DHandleImpl.cpp248 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 Drdkafkacpp_int.h641 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 Drdkafkacpp.h949 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 DHandleImpl.cpp246 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 Drdkafkacpp_int.h654 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 Drdkafkacpp.h1044 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 DHandleImpl.cpp248 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 Drdkafka_conf.h353 void (*offset_commit_cb) (rd_kafka_t *rk, member
/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_conf.h363 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 Drdkafka_conf.h362 void (*offset_commit_cb) (rd_kafka_t *rk,
/dports/net/librdkafka/librdkafka-1.8.2/examples/
H A Drdkafka_performance.c151 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 Drdkafka_performance.c151 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 Drdkafka_performance.c151 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()

12