Home
last modified time | relevance | path

Searched refs:RD_KAFKA_OFFSET_INVALID (Results 1 – 25 of 58) sorted by relevance

123

/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_offset.c85 else if (offset == RD_KAFKA_OFFSET_INVALID) in rd_kafka_offset2str()
193 return RD_KAFKA_OFFSET_INVALID; in rd_kafka_offset_file_read()
203 return RD_KAFKA_OFFSET_INVALID; in rd_kafka_offset_file_read()
217 return RD_KAFKA_OFFSET_INVALID; in rd_kafka_offset_file_read()
754 int64_t offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_offset_reset()
770 if (err_offset == RD_KAFKA_OFFSET_INVALID || err) in rd_kafka_offset_reset()
775 if (offset == RD_KAFKA_OFFSET_INVALID) { in rd_kafka_offset_reset()
805 offset == RD_KAFKA_OFFSET_INVALID) in rd_kafka_offset_reset()
898 int64_t offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_offset_file_init()
948 if (offset != RD_KAFKA_OFFSET_INVALID) { in rd_kafka_offset_file_init()
[all …]
H A Drdkafka_assignment.c182 RD_KAFKA_OFFSET_INVALID, in rd_kafka_assignment_apply_offsets()
277 RD_KAFKA_OFFSET_INVALID, in rd_kafka_assignment_handle_OffsetFetch()
296 RD_KAFKA_OFFSET_INVALID, in rd_kafka_assignment_handle_OffsetFetch()
363 rd_kafka_offset_store0(rktp, RD_KAFKA_OFFSET_INVALID, in rd_kafka_assignment_serve_removals()
451 rktpar->offset == RD_KAFKA_OFFSET_INVALID || in rd_kafka_assignment_serve_pending()
704 rktpar->offset != RD_KAFKA_OFFSET_INVALID && in rd_kafka_assignment_add()
733 if (rktpar->offset == RD_KAFKA_OFFSET_INVALID) in rd_kafka_assignment_add()
H A Drdkafka_partition.c239 rktp->rktp_ls_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0()
240 rktp->rktp_hi_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0()
241 rktp->rktp_lo_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0()
242 rktp->rktp_query_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0()
243 rktp->rktp_next_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0()
245 rktp->rktp_app_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0()
246 rktp->rktp_stored_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0()
1640 } else if (offset == RD_KAFKA_OFFSET_INVALID) { in rd_kafka_toppar_fetch_start()
2211 int64_t offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_op_serve()
2845 rktpar->offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_topic_partition_list_add0()
[all …]
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/
H A Drdkafka_offset.c87 else if (offset == RD_KAFKA_OFFSET_INVALID) in rd_kafka_offset2str()
195 return RD_KAFKA_OFFSET_INVALID; in rd_kafka_offset_file_read()
205 return RD_KAFKA_OFFSET_INVALID; in rd_kafka_offset_file_read()
219 return RD_KAFKA_OFFSET_INVALID; in rd_kafka_offset_file_read()
759 int64_t offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_offset_reset()
776 if (err_offset == RD_KAFKA_OFFSET_INVALID || err) in rd_kafka_offset_reset()
781 if (offset == RD_KAFKA_OFFSET_INVALID) { in rd_kafka_offset_reset()
896 int64_t offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_offset_file_init()
946 if (offset != RD_KAFKA_OFFSET_INVALID) { in rd_kafka_offset_file_init()
954 rktp->rktp_committed_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_offset_file_init()
[all …]
H A Drdkafka_partition.c220 rktp->rktp_ls_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0()
221 rktp->rktp_hi_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0()
222 rktp->rktp_lo_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0()
223 rktp->rktp_query_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0()
224 rktp->rktp_next_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0()
226 rktp->rktp_app_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0()
227 rktp->rktp_stored_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0()
1607 } else if (offset == RD_KAFKA_OFFSET_INVALID) { in rd_kafka_toppar_fetch_start()
2158 int64_t offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_op_serve()
2734 rktpar->offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_topic_partition_list_add0()
[all …]
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/
H A Drdkafka_offset.c85 else if (offset == RD_KAFKA_OFFSET_INVALID)
193 return RD_KAFKA_OFFSET_INVALID;
203 return RD_KAFKA_OFFSET_INVALID;
217 return RD_KAFKA_OFFSET_INVALID;
754 int64_t offset = RD_KAFKA_OFFSET_INVALID;
770 if (err_offset == RD_KAFKA_OFFSET_INVALID || err)
775 if (offset == RD_KAFKA_OFFSET_INVALID) {
883 int64_t offset = RD_KAFKA_OFFSET_INVALID;
933 if (offset != RD_KAFKA_OFFSET_INVALID) {
941 rktp->rktp_committed_offset = RD_KAFKA_OFFSET_INVALID;
[all …]
H A Drdkafka_assignment.c182 RD_KAFKA_OFFSET_INVALID, in rd_kafka_assignment_apply_offsets()
277 RD_KAFKA_OFFSET_INVALID, in rd_kafka_assignment_handle_OffsetFetch()
296 RD_KAFKA_OFFSET_INVALID, in rd_kafka_assignment_handle_OffsetFetch()
363 rd_kafka_offset_store0(rktp, RD_KAFKA_OFFSET_INVALID, in rd_kafka_assignment_serve_removals()
451 rktpar->offset == RD_KAFKA_OFFSET_INVALID || in rd_kafka_assignment_serve_pending()
704 rktpar->offset != RD_KAFKA_OFFSET_INVALID && in rd_kafka_assignment_add()
733 if (rktpar->offset == RD_KAFKA_OFFSET_INVALID) in rd_kafka_assignment_add()
H A Drdkafka_partition.c239 rktp->rktp_ls_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0()
240 rktp->rktp_hi_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0()
241 rktp->rktp_lo_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0()
242 rktp->rktp_query_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0()
243 rktp->rktp_next_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0()
245 rktp->rktp_app_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0()
246 rktp->rktp_stored_offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_new0()
1625 } else if (offset == RD_KAFKA_OFFSET_INVALID) { in rd_kafka_toppar_fetch_start()
2196 int64_t offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_toppar_op_serve()
2830 rktpar->offset = RD_KAFKA_OFFSET_INVALID; in rd_kafka_topic_partition_list_add0()
[all …]
/dports/net/librdkafka/librdkafka-1.8.2/tests/
H A D0104-fetch_from_follower_mock.c90 RD_KAFKA_OFFSET_INVALID); in do_test_offset_reset()
154 RD_KAFKA_OFFSET_INVALID); in do_test_offset_reset_lag()
219 RD_KAFKA_OFFSET_INVALID); in do_test_unknown_follower()
298 RD_KAFKA_OFFSET_INVALID); in do_test_replica_not_available()
H A D0020-destroy_hang.c113 RD_KAFKA_OFFSET_INVALID) in nonexist_part()
H A D0029-assign_offset.c84 parts->elems[i].offset = RD_KAFKA_OFFSET_INVALID; in rebalance_cb()
H A D0117-mock_errors.c253 RD_KAFKA_OFFSET_INVALID; in do_test_offset_commit_request_timed_out()
H A D0026-consume_pause.c323 toppar->offset = RD_KAFKA_OFFSET_INVALID; in consume_pause_resume_after_reassign()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/
H A D0104-fetch_from_follower_mock.c90 RD_KAFKA_OFFSET_INVALID); in do_test_offset_reset()
154 RD_KAFKA_OFFSET_INVALID); in do_test_offset_reset_lag()
219 RD_KAFKA_OFFSET_INVALID); in do_test_unknown_follower()
298 RD_KAFKA_OFFSET_INVALID); in do_test_replica_not_available()
H A D0020-destroy_hang.c113 RD_KAFKA_OFFSET_INVALID) in nonexist_part()
H A D0029-assign_offset.c84 parts->elems[i].offset = RD_KAFKA_OFFSET_INVALID;
H A D0026-consume_pause.c323 toppar->offset = RD_KAFKA_OFFSET_INVALID;
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/
H A D0104-fetch_from_follower_mock.c90 RD_KAFKA_OFFSET_INVALID); in do_test_offset_reset()
154 RD_KAFKA_OFFSET_INVALID); in do_test_offset_reset_lag()
218 RD_KAFKA_OFFSET_INVALID); in do_test_unknown_follower()
H A D0020-destroy_hang.c113 RD_KAFKA_OFFSET_INVALID) in nonexist_part()
H A D0029-assign_offset.c84 parts->elems[i].offset = RD_KAFKA_OFFSET_INVALID; in rebalance_cb()
H A D0026-consume_pause.c323 toppar->offset = RD_KAFKA_OFFSET_INVALID; in consume_pause_resume_after_reassign()
/dports/net/librdkafka/librdkafka-1.8.2/src-cpp/
H A DTopicImpl.cpp44 const int64_t RdKafka::Topic::OFFSET_INVALID = RD_KAFKA_OFFSET_INVALID;
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src-cpp/
H A DTopicImpl.cpp44 const int64_t RdKafka::Topic::OFFSET_INVALID = RD_KAFKA_OFFSET_INVALID;
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src-cpp/
H A DTopicImpl.cpp44 const int64_t RdKafka::Topic::OFFSET_INVALID = RD_KAFKA_OFFSET_INVALID;
/dports/net/kcat/kcat-1.7.0/
H A Dkcat.c72 .offset = RD_KAFKA_OFFSET_INVALID,
724 if (conf.offset != RD_KAFKA_OFFSET_INVALID) in incremental_rebalance_cb()
794 if (conf.offset != RD_KAFKA_OFFSET_INVALID) { in rebalance_cb()
1037 RD_KAFKA_OFFSET_INVALID ? in consumer_run()

123