| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdkafka_assignment.c | 146 rktpar->topic, rktpar->partition)) { in rd_kafka_assignment_apply_offsets()
186 rktpar->topic, rktpar->partition, in rd_kafka_assignment_apply_offsets()
331 rktpar->topic, rktpar->partition); in rd_kafka_assignment_serve_removals()
334 rktpar->topic, rktpar->partition); in rd_kafka_assignment_serve_removals()
374 rktpar->topic, rktpar->partition, in rd_kafka_assignment_serve_removals()
710 rktpar->topic, rktpar->partition, in rd_kafka_assignment_add()
721 rktpar->topic, rktpar->partition)) in rd_kafka_assignment_add()
805 rktpar->topic, rktpar->partition)) in rd_kafka_assignment_subtract()
828 rktpar->topic, rktpar->partition)) in rd_kafka_assignment_subtract()
831 rktpar->topic, rktpar->partition); in rd_kafka_assignment_subtract()
[all …]
|
| H A D | rdkafka_partition.c | 2539 rktpar->topic, rktpar->partition); in rd_kafka_toppars_pause_resume()
2723 rd_kafka_topic_partition_t *rktpar = rd_calloc(1, sizeof(*rktpar)); in rd_kafka_topic_partition_new() local
2728 return rktpar; in rd_kafka_topic_partition_new()
2746 rd_kafka_topic_partition_t *rktpar = rd_calloc(1, sizeof(*rktpar)); in rd_kafka_topic_partition_new_from_rktp() local
2751 return rktpar; in rd_kafka_topic_partition_new_from_rktp()
2766 rd_free(rktpar); in rd_kafka_topic_partition_destroy0()
2842 memset(rktpar, 0, sizeof(*rktpar)); in rd_kafka_topic_partition_list_add0()
3440 rktpar->topic, rktpar->partition, in rd_kafka_topic_partition_list_get_leaders()
3980 rktpar->topic, rktpar->partition, in rd_kafka_topic_partition_list_log()
3983 rktpar->err ? rd_kafka_err2str(rktpar->err) : ""); in rd_kafka_topic_partition_list_log()
[all …]
|
| H A D | rdkafka_offset.c | 418 rd_kafka_topic_partition_t *rktpar; in rd_kafka_commit_message() local
425 rktpar = rd_kafka_topic_partition_list_add( in rd_kafka_commit_message()
428 rktpar->offset = rkmessage->offset+1; in rd_kafka_commit_message()
503 rd_kafka_topic_partition_t *rktpar; in rd_kafka_offset_broker_commit_cb() local
511 rktpar = &offsets->elems[0]; in rd_kafka_offset_broker_commit_cb()
519 rktpar->topic, in rd_kafka_offset_broker_commit_cb()
520 rktpar->partition, in rd_kafka_offset_broker_commit_cb()
521 rktpar->offset, in rd_kafka_offset_broker_commit_cb()
522 rd_kafka_err2str(rktpar->err)); in rd_kafka_offset_broker_commit_cb()
527 err = rktpar->err; in rd_kafka_offset_broker_commit_cb()
[all …]
|
| H A D | rdkafka_request.c | 308 if (rktpar->offset < 0) { in rd_kafka_buf_write_topic_partitions()
800 if (!(rktp = rktpar->_private)) { in rd_kafka_handle_OffsetFetch()
805 rktpar->_private = rktp; in rd_kafka_handle_OffsetFetch()
812 rktpar->offset = offset; in rd_kafka_handle_OffsetFetch()
830 if (rktpar->err == in rd_kafka_handle_OffsetFetch()
1176 if (!rktpar) { in rd_kafka_handle_OffsetCommit()
1310 if (rktpar->offset < 0) in rd_kafka_OffsetCommitRequest()
1326 last_topic = rktpar->topic; in rd_kafka_OffsetCommitRequest()
1350 if (!rktpar->metadata) in rd_kafka_OffsetCommitRequest()
1354 rktpar->metadata, in rd_kafka_OffsetCommitRequest()
[all …]
|
| H A D | rdkafka_event.c | 281 rd_kafka_topic_partition_t *rktpar; in rd_kafka_event_topic_partition() local
286 rktpar = rd_kafka_topic_partition_new_from_rktp(rkev->rko_rktp); in rd_kafka_event_topic_partition()
292 rktpar->offset = rkev->rko_u.err.offset; in rd_kafka_event_topic_partition()
298 rktpar->err = rkev->rko_err; in rd_kafka_event_topic_partition()
300 return rktpar; in rd_kafka_event_topic_partition()
|
| H A D | rdkafka_subscription.c | 51 static size_t _invalid_topic_cb (const rd_kafka_topic_partition_t *rktpar, in _invalid_topic_cb() argument
56 if (!*rktpar->topic) in _invalid_topic_cb()
59 if (*rktpar->topic != '^') in _invalid_topic_cb()
62 if (!(re = rd_regex_comp(rktpar->topic, errstr, sizeof(errstr)))) in _invalid_topic_cb()
|
| H A D | rdkafka_partition.h | 584 const rd_kafka_topic_partition_t *rktpar);
614 const rd_kafka_topic_partition_t *rktpar,
651 rd_kafka_topic_partition_t *rktpar,
656 rd_kafka_topic_partition_t *rktpar,
716 const rd_kafka_topic_partition_t *rktpar = elem; in rd_kafka_topic_partition_match_valid_offset() local
717 return rktpar->offset >= 0; in rd_kafka_topic_partition_match_valid_offset()
728 size_t (*cb) (const rd_kafka_topic_partition_t *rktpar, void *opaque),
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdkafka_assignment.c | 146 rktpar->topic, rktpar->partition)) { in rd_kafka_assignment_apply_offsets()
186 rktpar->topic, rktpar->partition, in rd_kafka_assignment_apply_offsets()
331 rktpar->topic, rktpar->partition); in rd_kafka_assignment_serve_removals()
334 rktpar->topic, rktpar->partition); in rd_kafka_assignment_serve_removals()
374 rktpar->topic, rktpar->partition, in rd_kafka_assignment_serve_removals()
710 rktpar->topic, rktpar->partition, in rd_kafka_assignment_add()
721 rktpar->topic, rktpar->partition)) in rd_kafka_assignment_add()
805 rktpar->topic, rktpar->partition)) in rd_kafka_assignment_subtract()
828 rktpar->topic, rktpar->partition)) in rd_kafka_assignment_subtract()
831 rktpar->topic, rktpar->partition); in rd_kafka_assignment_subtract()
[all …]
|
| H A D | rdkafka_partition.c | 2524 rktpar->topic, rktpar->partition); in rd_kafka_toppars_pause_resume()
2708 rd_kafka_topic_partition_t *rktpar = rd_calloc(1, sizeof(*rktpar)); in rd_kafka_topic_partition_new() local
2713 return rktpar; in rd_kafka_topic_partition_new()
2731 rd_kafka_topic_partition_t *rktpar = rd_calloc(1, sizeof(*rktpar)); in rd_kafka_topic_partition_new_from_rktp() local
2736 return rktpar; in rd_kafka_topic_partition_new_from_rktp()
2751 rd_free(rktpar); in rd_kafka_topic_partition_destroy0()
2827 memset(rktpar, 0, sizeof(*rktpar)); in rd_kafka_topic_partition_list_add0()
3425 rktpar->topic, rktpar->partition, in rd_kafka_topic_partition_list_get_leaders()
3965 rktpar->topic, rktpar->partition, in rd_kafka_topic_partition_list_log()
3968 rktpar->err ? rd_kafka_err2str(rktpar->err) : ""); in rd_kafka_topic_partition_list_log()
[all …]
|
| H A D | rdkafka_offset.c | 418 rd_kafka_topic_partition_t *rktpar;
425 rktpar = rd_kafka_topic_partition_list_add(
428 rktpar->offset = rkmessage->offset+1;
503 rd_kafka_topic_partition_t *rktpar;
511 rktpar = &offsets->elems[0];
519 rktpar->topic,
520 rktpar->partition,
521 rktpar->offset,
522 rd_kafka_err2str(rktpar->err));
527 err = rktpar->err;
[all …]
|
| H A D | rdkafka_request.c | 304 if (rktpar->offset < 0) { in rd_kafka_buf_write_topic_partitions()
725 if (!(rktp = rktpar->_private)) { in rd_kafka_handle_OffsetFetch()
730 rktpar->_private = rktp; in rd_kafka_handle_OffsetFetch()
737 rktpar->offset = offset; in rd_kafka_handle_OffsetFetch()
755 if (rktpar->err == in rd_kafka_handle_OffsetFetch()
1096 if (!rktpar) { in rd_kafka_handle_OffsetCommit()
1235 if (rktpar->offset < 0) in rd_kafka_OffsetCommitRequest()
1251 last_topic = rktpar->topic; in rd_kafka_OffsetCommitRequest()
1275 if (!rktpar->metadata) in rd_kafka_OffsetCommitRequest()
1279 rktpar->metadata, in rd_kafka_OffsetCommitRequest()
[all …]
|
| H A D | rdkafka_event.c | 281 rd_kafka_topic_partition_t *rktpar; in rd_kafka_event_topic_partition() local
286 rktpar = rd_kafka_topic_partition_new_from_rktp(rkev->rko_rktp); in rd_kafka_event_topic_partition()
292 rktpar->offset = rkev->rko_u.err.offset; in rd_kafka_event_topic_partition()
298 rktpar->err = rkev->rko_err; in rd_kafka_event_topic_partition()
300 return rktpar; in rd_kafka_event_topic_partition()
|
| H A D | rdkafka_subscription.c | 51 static size_t _invalid_topic_cb (const rd_kafka_topic_partition_t *rktpar, in _invalid_topic_cb() argument
56 if (!*rktpar->topic) in _invalid_topic_cb()
59 if (*rktpar->topic != '^') in _invalid_topic_cb()
62 if (!(re = rd_regex_comp(rktpar->topic, errstr, sizeof(errstr)))) in _invalid_topic_cb()
|
| H A D | rdkafka_partition.h | 584 const rd_kafka_topic_partition_t *rktpar);
614 const rd_kafka_topic_partition_t *rktpar,
651 rd_kafka_topic_partition_t *rktpar,
656 rd_kafka_topic_partition_t *rktpar,
716 const rd_kafka_topic_partition_t *rktpar = elem; in rd_kafka_topic_partition_match_valid_offset() local
717 return rktpar->offset >= 0; in rd_kafka_topic_partition_match_valid_offset()
728 size_t (*cb) (const rd_kafka_topic_partition_t *rktpar, void *opaque),
|
| /dports/net/librdkafka/librdkafka-1.8.2/examples/ |
| H A D | transactions-older-broker.c | 162 rktpar->topic, rktpar->partition); in create_transactional_producer()
238 state->rktpar->topic, state->rktpar->partition); in abort_transaction_and_rewind()
260 state->rktpar->topic, (int)state->rktpar->partition, in abort_transaction_and_rewind()
275 state->rktpar->topic, (int)state->rktpar->partition, in abort_transaction_and_rewind()
292 state->rktpar->topic, state->rktpar->partition); in commit_transaction_and_start_new()
310 state->rktpar->topic, state->rktpar->partition, in commit_transaction_and_start_new()
394 state->rktpar = rktpar; in consumer_group_rebalance_cb()
395 rktpar->opaque = state; in consumer_group_rebalance_cb()
400 rktpar->topic, rktpar->partition, in consumer_group_rebalance_cb()
618 rd_kafka_topic_partition_t *rktpar; in main() local
[all …]
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/examples/ |
| H A D | transactions.c | 159 rktpar->topic, rktpar->partition); in create_transactional_producer()
233 state->rktpar->topic, state->rktpar->partition); in abort_transaction_and_rewind()
255 state->rktpar->topic, (int)state->rktpar->partition, in abort_transaction_and_rewind()
270 state->rktpar->topic, (int)state->rktpar->partition, in abort_transaction_and_rewind()
287 state->rktpar->topic, state->rktpar->partition); in commit_transaction_and_start_new()
305 state->rktpar->topic, state->rktpar->partition, in commit_transaction_and_start_new()
384 state->rktpar = rktpar; in consumer_group_rebalance_cb()
385 rktpar->opaque = state; in consumer_group_rebalance_cb()
390 rktpar->topic, rktpar->partition, in consumer_group_rebalance_cb()
608 rd_kafka_topic_partition_t *rktpar; in main() local
[all …]
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/examples/ |
| H A D | transactions-older-broker.c | 162 rktpar->topic, rktpar->partition); in create_transactional_producer()
238 state->rktpar->topic, state->rktpar->partition); in abort_transaction_and_rewind()
260 state->rktpar->topic, (int)state->rktpar->partition, in abort_transaction_and_rewind()
275 state->rktpar->topic, (int)state->rktpar->partition, in abort_transaction_and_rewind()
292 state->rktpar->topic, state->rktpar->partition); in commit_transaction_and_start_new()
310 state->rktpar->topic, state->rktpar->partition, in commit_transaction_and_start_new()
394 state->rktpar = rktpar; in consumer_group_rebalance_cb()
395 rktpar->opaque = state; in consumer_group_rebalance_cb()
400 rktpar->topic, rktpar->partition, in consumer_group_rebalance_cb()
618 rd_kafka_topic_partition_t *rktpar; in main() local
[all …]
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
| H A D | rdkafka_partition.c | 2483 rktpar->topic, rktpar->partition); in rd_kafka_toppars_pause_resume()
2655 rd_kafka_topic_partition_t *rktpar = rd_calloc(1, sizeof(*rktpar)); in rd_kafka_topic_partition_new() local
2660 return rktpar; in rd_kafka_topic_partition_new()
2666 rd_kafka_topic_partition_t *rktpar = rd_calloc(1, sizeof(*rktpar)); in rd_kafka_topic_partition_new_from_rktp() local
2671 return rktpar; in rd_kafka_topic_partition_new_from_rktp()
2678 if (rktpar->topic) in rd_kafka_topic_partition_destroy0()
2687 rd_free(rktpar); in rd_kafka_topic_partition_destroy0()
2731 memset(rktpar, 0, sizeof(*rktpar)); in rd_kafka_topic_partition_list_add0()
3468 rktpar->topic, rktpar->partition, in rd_kafka_topic_partition_list_log()
3471 rktpar->err ? rd_kafka_err2str(rktpar->err) : ""); in rd_kafka_topic_partition_list_log()
[all …]
|
| H A D | rdkafka_request.c | 622 if (!rktpar) { in rd_kafka_handle_OffsetFetch()
632 if (!(s_rktp = rktpar->_private)) { in rd_kafka_handle_OffsetFetch()
637 rktpar->_private = s_rktp; in rd_kafka_handle_OffsetFetch()
644 rktpar->offset = offset; in rd_kafka_handle_OffsetFetch()
824 rktpar->topic, rktpar->partition, in rd_kafka_OffsetFetchRequest()
842 last_topic = rktpar->topic; in rd_kafka_OffsetFetchRequest()
1091 if (rktpar->offset < 0) in rd_kafka_OffsetCommitRequest()
1107 last_topic = rktpar->topic; in rd_kafka_OffsetCommitRequest()
1131 if (!rktpar->metadata) in rd_kafka_OffsetCommitRequest()
1135 rktpar->metadata, in rd_kafka_OffsetCommitRequest()
[all …]
|
| H A D | rdkafka_offset.c | 420 rd_kafka_topic_partition_t *rktpar; in rd_kafka_commit_message() local
427 rktpar = rd_kafka_topic_partition_list_add( in rd_kafka_commit_message()
430 rktpar->offset = rkmessage->offset+1; in rd_kafka_commit_message()
506 rd_kafka_topic_partition_t *rktpar; in rd_kafka_offset_broker_commit_cb() local
514 rktpar = &offsets->elems[0]; in rd_kafka_offset_broker_commit_cb()
521 rktpar->topic, in rd_kafka_offset_broker_commit_cb()
522 rktpar->partition, in rd_kafka_offset_broker_commit_cb()
523 rktpar->offset, in rd_kafka_offset_broker_commit_cb()
524 rd_kafka_err2str(rktpar->err)); in rd_kafka_offset_broker_commit_cb()
531 err = rktpar->err; in rd_kafka_offset_broker_commit_cb()
[all …]
|
| H A D | rdkafka_subscription.c | 51 static size_t _invalid_topic_cb (const rd_kafka_topic_partition_t *rktpar, in _invalid_topic_cb() argument
56 if (!*rktpar->topic) in _invalid_topic_cb()
59 if (*rktpar->topic != '^') in _invalid_topic_cb()
62 if (!(re = rd_regex_comp(rktpar->topic, errstr, sizeof(errstr)))) in _invalid_topic_cb()
|
| H A D | rdkafka_event.c | 247 rd_kafka_topic_partition_t *rktpar; in rd_kafka_event_topic_partition() local
252 rktpar = rd_kafka_topic_partition_new_from_rktp( in rd_kafka_event_topic_partition()
259 rktpar->offset = rkev->rko_u.err.offset; in rd_kafka_event_topic_partition()
265 rktpar->err = rkev->rko_err; in rd_kafka_event_topic_partition()
267 return rktpar; in rd_kafka_event_topic_partition()
|
| /dports/net/librdkafka/librdkafka-1.8.2/tests/ |
| H A D | 0030-offset_commit.c | 53 rd_kafka_topic_partition_t *rktpar; in offset_commit_cb() local
70 if (rktpar->err) in offset_commit_cb()
72 rd_kafka_err2str(rktpar->err)); in offset_commit_cb()
74 if (rktpar->offset > expected_offset) in offset_commit_cb()
77 rktpar->offset, expected_offset); in offset_commit_cb()
89 if (rktpar->offset < expected_offset) { in offset_commit_cb()
92 rktpar->offset, expected_offset); in offset_commit_cb()
111 rd_kafka_topic_partition_t *rktpar; in do_offset_test() local
220 if (rktpar->offset != next_offset) in do_offset_test()
224 what, rktpar->offset); in do_offset_test()
[all …]
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
| H A D | 0030-offset_commit.c | 53 rd_kafka_topic_partition_t *rktpar; in offset_commit_cb() local
70 if (rktpar->err) in offset_commit_cb()
72 rd_kafka_err2str(rktpar->err)); in offset_commit_cb()
74 if (rktpar->offset > expected_offset) in offset_commit_cb()
77 rktpar->offset, expected_offset); in offset_commit_cb()
89 if (rktpar->offset < expected_offset) { in offset_commit_cb()
92 rktpar->offset, expected_offset); in offset_commit_cb()
111 rd_kafka_topic_partition_t *rktpar; in do_offset_test() local
214 if (rktpar->offset != next_offset) in do_offset_test()
218 what, rktpar->offset); in do_offset_test()
[all …]
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
| H A D | 0030-offset_commit.c | 53 rd_kafka_topic_partition_t *rktpar; in offset_commit_cb() local
70 if (rktpar->err) in offset_commit_cb()
72 rd_kafka_err2str(rktpar->err)); in offset_commit_cb()
74 if (rktpar->offset > expected_offset) in offset_commit_cb()
77 rktpar->offset, expected_offset); in offset_commit_cb()
89 if (rktpar->offset < expected_offset) { in offset_commit_cb()
92 rktpar->offset, expected_offset); in offset_commit_cb()
111 rd_kafka_topic_partition_t *rktpar; in do_offset_test() local
216 if (rktpar->offset != next_offset) in do_offset_test()
220 what, rktpar->offset); in do_offset_test()
[all …]
|