Searched refs:RD_KAFKA_OP_FETCH_STOP (Results 1 – 12 of 12) sorted by relevance
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
| H A D | rdkafka_op.c | 57 [RD_KAFKA_OP_FETCH_STOP] = "REPLY:FETCH_STOP", in rd_kafka_op2str()
182 [RD_KAFKA_OP_FETCH_STOP] = 0, in rd_kafka_op_new0()
|
| H A D | rdkafka_op.h | 89 RD_KAFKA_OP_FETCH_STOP, /* Application -> toppar's handler thread */ enumerator
|
| H A D | rdkafka_partition.c | 1670 rko = rd_kafka_op_new(RD_KAFKA_OP_FETCH_STOP|RD_KAFKA_OP_REPLY); in rd_kafka_toppar_fetch_stopped()
2132 case RD_KAFKA_OP_FETCH_STOP: in rd_kafka_toppar_op_serve()
2341 rd_kafka_toppar_op(rktp, RD_KAFKA_OP_FETCH_STOP, version, in rd_kafka_toppar_op_fetch_stop()
|
| H A D | rdkafka_cgrp.c | 3108 case RD_KAFKA_OP_FETCH_STOP|RD_KAFKA_OP_REPLY: in rd_kafka_cgrp_op_serve()
|
| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdkafka_op.c | 58 [RD_KAFKA_OP_FETCH_STOP] = "REPLY:FETCH_STOP", in rd_kafka_op2str()
198 [RD_KAFKA_OP_FETCH_STOP] = _RD_KAFKA_OP_EMPTY, in rd_kafka_op_new0()
|
| H A D | rdkafka_op.h | 94 RD_KAFKA_OP_FETCH_STOP, /* Application -> toppar's handler thread */ enumerator
|
| H A D | rdkafka_partition.c | 1703 rko = rd_kafka_op_new(RD_KAFKA_OP_FETCH_STOP|RD_KAFKA_OP_REPLY); in rd_kafka_toppar_fetch_stopped()
2186 case RD_KAFKA_OP_FETCH_STOP: in rd_kafka_toppar_op_serve()
2397 rd_kafka_toppar_op(rktp, RD_KAFKA_OP_FETCH_STOP, version, in rd_kafka_toppar_op_fetch_stop()
|
| H A D | rdkafka.c | 3729 case RD_KAFKA_OP_FETCH_STOP|RD_KAFKA_OP_REPLY: in rd_kafka_poll_cb()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdkafka_op.c | 58 [RD_KAFKA_OP_FETCH_STOP] = "REPLY:FETCH_STOP", in rd_kafka_op2str()
198 [RD_KAFKA_OP_FETCH_STOP] = _RD_KAFKA_OP_EMPTY, in rd_kafka_op_new0()
|
| H A D | rdkafka_op.h | 89 RD_KAFKA_OP_FETCH_STOP, /* Application -> toppar's handler thread */
|
| H A D | rdkafka_partition.c | 1688 rko = rd_kafka_op_new(RD_KAFKA_OP_FETCH_STOP|RD_KAFKA_OP_REPLY); in rd_kafka_toppar_fetch_stopped()
2171 case RD_KAFKA_OP_FETCH_STOP: in rd_kafka_toppar_op_serve()
2382 rd_kafka_toppar_op(rktp, RD_KAFKA_OP_FETCH_STOP, version, in rd_kafka_toppar_op_fetch_stop()
|
| H A D | rdkafka.c | 3728 case RD_KAFKA_OP_FETCH_STOP|RD_KAFKA_OP_REPLY:
|