Home
last modified time | relevance | path

Searched refs:RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED (Results 1 – 19 of 19) sorted by relevance

/dports/net/kcat/kcat-1.7.0/
H A Dtools.c67 err = RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED; in query_offsets_by_time()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/src/
H A Dhelpers.rs40 RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED => NotImplemented, in rd_kafka_resp_err_t_to_rdkafka_error()
H A Dbindings.rs144 RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED = -170, enumerator
/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_msgset_reader.c433 err = RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED; in rd_kafka_msgset_reader_decompress()
1215 RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED, in rd_kafka_msgset_reader_peek_msg_version()
1230 return RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED; in rd_kafka_msgset_reader_peek_msg_version()
H A Drdkafka.c311 return RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED; in rd_kafka_oauthbearer_set_token()
320 return RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED; in rd_kafka_oauthbearer_set_token_failure()
440 _ERR_DESC(RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED,
4221 return RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED; in rd_kafka_flush()
4323 return RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED; in rd_kafka_purge()
H A Drdkafka_queue.c943 rko->rko_err != RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED) { in rd_kafka_q_fix_offsets()
H A Drdkafka.h334 RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED = -170, enumerator
H A Drdkafka_admin.c1348 return RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED; in rd_kafka_AdminOptions_set_incremental()
/dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/
H A Drdkafka_msgset_reader.c431 err = RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED; in rd_kafka_msgset_reader_decompress()
1189 RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED, in rd_kafka_msgset_reader_peek_msg_version()
1204 return RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED; in rd_kafka_msgset_reader_peek_msg_version()
H A Drdkafka.c322 return RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED; in rd_kafka_oauthbearer_set_token()
331 return RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED; in rd_kafka_oauthbearer_set_token_failure()
451 _ERR_DESC(RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED,
4019 return RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED; in rd_kafka_flush()
4076 return RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED; in rd_kafka_purge()
H A Drdkafka_queue.c891 rko->rko_err != RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED) { in rd_kafka_q_fix_offsets()
H A Drdkafka.h323 RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED = -170, enumerator
H A Drdkafka_admin.c886 return RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED; in rd_kafka_AdminOptions_set_incremental()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/
H A Drdkafka_msgset_reader.c433 err = RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED; in rd_kafka_msgset_reader_decompress()
1215 RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED, in rd_kafka_msgset_reader_peek_msg_version()
1230 return RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED; in rd_kafka_msgset_reader_peek_msg_version()
H A Drdkafka.c311 return RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED;
320 return RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED;
440 _ERR_DESC(RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED,
4220 return RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED;
4311 return RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED;
H A Drdkafka_queue.c943 rko->rko_err != RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED) { in rd_kafka_q_fix_offsets()
H A Drdkafka.h334 RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED = -170, enumerator
H A Drdkafka_admin.c1339 return RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED;
/dports/net/py-confluent-kafka/confluent-kafka-1.2.0/confluent_kafka/src/
H A DAdmin.c296 err = RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED; in Admin_config_dict_to_c()