Home
last modified time | relevance | path

Searched refs:RD_KAFKA_ASSIGN_METHOD_ASSIGN (Results 1 – 6 of 6) sorted by relevance

/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_subscription.c134 error = rd_kafka_assign0(rk, RD_KAFKA_ASSIGN_METHOD_ASSIGN, in rd_kafka_assign()
H A Drdkafka_op.h216 RD_KAFKA_ASSIGN_METHOD_ASSIGN, /**< Absolute assign/unassign */ enumerator
H A Drdkafka_cgrp.c4897 !(rko->rko_u.assign.method == RD_KAFKA_ASSIGN_METHOD_ASSIGN)) in rd_kafka_cgrp_handle_assign_op()
4921 rko->rko_u.assign.method = RD_KAFKA_ASSIGN_METHOD_ASSIGN; in rd_kafka_cgrp_handle_assign_op()
4927 case RD_KAFKA_ASSIGN_METHOD_ASSIGN: in rd_kafka_cgrp_handle_assign_op()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/
H A Drdkafka_subscription.c134 error = rd_kafka_assign0(rk, RD_KAFKA_ASSIGN_METHOD_ASSIGN, in rd_kafka_assign()
H A Drdkafka_op.h211 RD_KAFKA_ASSIGN_METHOD_ASSIGN, /**< Absolute assign/unassign */
H A Drdkafka_cgrp.c4638 !(rko->rko_u.assign.method == RD_KAFKA_ASSIGN_METHOD_ASSIGN)) in rd_kafka_cgrp_handle_assign_op()
4662 rko->rko_u.assign.method = RD_KAFKA_ASSIGN_METHOD_ASSIGN; in rd_kafka_cgrp_handle_assign_op()
4668 case RD_KAFKA_ASSIGN_METHOD_ASSIGN: in rd_kafka_cgrp_handle_assign_op()