Searched refs:RD_KAFKA_RESP_ERR__RETRY (Results 1 – 17 of 17) sorted by relevance
| /dports/net/librdkafka/librdkafka-1.8.2/tests/ |
| H A D | 0090-idempotence.c | 61 if (err == RD_KAFKA_RESP_ERR__RETRY) in handle_ProduceResponse()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
| H A D | 0090-idempotence.c | 61 if (err == RD_KAFKA_RESP_ERR__RETRY) in handle_ProduceResponse()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
| H A D | 0090-idempotence.c | 61 if (err == RD_KAFKA_RESP_ERR__RETRY) in handle_ProduceResponse()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/src/ |
| H A D | helpers.rs | 57 RD_KAFKA_RESP_ERR__RETRY => Retry, in rd_kafka_resp_err_t_to_rdkafka_error()
|
| H A D | bindings.rs | 161 RD_KAFKA_RESP_ERR__RETRY = -153, enumerator
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
| H A D | rdkafka_broker.c | 2975 RD_KAFKA_RESP_ERR__RETRY); in rd_kafka_broker_op_serve()
3499 RD_KAFKA_RESP_ERR__RETRY); in rd_kafka_toppar_producer_serve()
3542 RD_KAFKA_RESP_ERR__RETRY); in rd_kafka_toppar_producer_serve()
|
| H A D | rdkafka.h | 357 RD_KAFKA_RESP_ERR__RETRY = -153, enumerator
|
| H A D | rdkafka_request.c | 2754 RD_KAFKA_RESP_ERR__RETRY, in rd_kafka_handle_Produce_error()
|
| H A D | rdkafka.c | 485 _ERR_DESC(RD_KAFKA_RESP_ERR__RETRY,
|
| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdkafka_broker.c | 3266 RD_KAFKA_RESP_ERR__RETRY); in rd_kafka_broker_op_serve()
3811 RD_KAFKA_RESP_ERR__RETRY); in rd_kafka_toppar_producer_serve()
3854 RD_KAFKA_RESP_ERR__RETRY); in rd_kafka_toppar_producer_serve()
|
| H A D | rdkafka.h | 368 RD_KAFKA_RESP_ERR__RETRY = -153, enumerator
|
| H A D | rdkafka_request.c | 2956 RD_KAFKA_RESP_ERR__RETRY, in rd_kafka_handle_Produce_error()
|
| H A D | rdkafka.c | 474 _ERR_DESC(RD_KAFKA_RESP_ERR__RETRY,
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdkafka_broker.c | 3218 RD_KAFKA_RESP_ERR__RETRY); in rd_kafka_broker_op_serve()
3760 RD_KAFKA_RESP_ERR__RETRY); in rd_kafka_toppar_producer_serve()
3803 RD_KAFKA_RESP_ERR__RETRY); in rd_kafka_toppar_producer_serve()
|
| H A D | rdkafka.h | 368 RD_KAFKA_RESP_ERR__RETRY = -153, enumerator
|
| H A D | rdkafka_request.c | 2951 RD_KAFKA_RESP_ERR__RETRY, in rd_kafka_handle_Produce_error()
|
| H A D | rdkafka.c | 474 _ERR_DESC(RD_KAFKA_RESP_ERR__RETRY,
|