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 D | tools.c | 67 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 D | helpers.rs | 40 RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED => NotImplemented, in rd_kafka_resp_err_t_to_rdkafka_error()
|
H A D | bindings.rs | 144 RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED = -170, enumerator
|
/dports/net/librdkafka/librdkafka-1.8.2/src/ |
H A D | rdkafka_msgset_reader.c | 433 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 D | rdkafka.c | 311 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 D | rdkafka_queue.c | 943 rko->rko_err != RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED) { in rd_kafka_q_fix_offsets()
|
H A D | rdkafka.h | 334 RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED = -170, enumerator
|
H A D | rdkafka_admin.c | 1348 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 D | rdkafka_msgset_reader.c | 431 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 D | rdkafka.c | 322 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 D | rdkafka_queue.c | 891 rko->rko_err != RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED) { in rd_kafka_q_fix_offsets()
|
H A D | rdkafka.h | 323 RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED = -170, enumerator
|
H A D | rdkafka_admin.c | 886 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 D | rdkafka_msgset_reader.c | 433 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 D | rdkafka.c | 311 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 D | rdkafka_queue.c | 943 rko->rko_err != RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED) { in rd_kafka_q_fix_offsets()
|
H A D | rdkafka.h | 334 RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED = -170, enumerator
|
H A D | rdkafka_admin.c | 1339 return RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED;
|
/dports/net/py-confluent-kafka/confluent-kafka-1.2.0/confluent_kafka/src/ |
H A D | Admin.c | 296 err = RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED; in Admin_config_dict_to_c()
|