| /dports/net/py-confluent-kafka/confluent-kafka-1.2.0/confluent_kafka/src/ |
| H A D | Metadata.c | 344 rd_kafka_topic_t *only_rkt = NULL; in list_topics() local
354 if (!(only_rkt = rd_kafka_topic_new(self->rk, in list_topics()
366 err = rd_kafka_metadata(self->rk, !only_rkt, only_rkt, &metadata, in list_topics()
389 if (only_rkt != NULL) { in list_topics()
390 rd_kafka_topic_destroy(only_rkt); in list_topics()
|
| /dports/net/librdkafka/librdkafka-1.8.2/src-cpp/ |
| H A D | HandleImpl.cpp | 182 const Topic *only_rkt, in metadata() argument
188 rd_kafka_topic_t *topic = only_rkt ? in metadata()
189 static_cast<const TopicImpl *>(only_rkt)->rkt_ : NULL; in metadata()
|
| H A D | rdkafkacpp.h | 1518 virtual ErrorCode metadata (bool all_topics, const Topic *only_rkt,
|
| H A D | rdkafkacpp_int.h | 905 RdKafka::ErrorCode metadata (bool all_topics,const Topic *only_rkt,
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src-cpp/ |
| H A D | HandleImpl.cpp | 180 const Topic *only_rkt, in metadata() argument
186 rd_kafka_topic_t *topic = only_rkt ? in metadata()
187 static_cast<const TopicImpl *>(only_rkt)->rkt_ : NULL; in metadata()
|
| H A D | rdkafkacpp.h | 1405 virtual ErrorCode metadata (bool all_topics, const Topic *only_rkt,
|
| H A D | rdkafkacpp_int.h | 880 RdKafka::ErrorCode metadata (bool all_topics,const Topic *only_rkt,
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src-cpp/ |
| H A D | HandleImpl.cpp | 182 const Topic *only_rkt, in metadata() argument
188 rd_kafka_topic_t *topic = only_rkt ? in metadata()
189 static_cast<const TopicImpl *>(only_rkt)->rkt_ : NULL; in metadata()
|
| H A D | rdkafkacpp.h | 1515 virtual ErrorCode metadata (bool all_topics, const Topic *only_rkt,
|
| H A D | rdkafkacpp_int.h | 905 RdKafka::ErrorCode metadata (bool all_topics,const Topic *only_rkt,
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
| H A D | rdkafka_metadata.c | 44 rd_kafka_topic_t *only_rkt, in rd_kafka_metadata() argument
64 if (only_rkt) in rd_kafka_metadata()
66 rd_strdup(rd_kafka_topic_a2i(only_rkt)-> in rd_kafka_metadata()
|
| H A D | rdkafka.h | 4181 rd_kafka_topic_t *only_rkt,
|
| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdkafka_metadata.c | 44 rd_kafka_topic_t *only_rkt, in rd_kafka_metadata() argument
66 if (only_rkt) in rd_kafka_metadata()
68 rd_strdup(rd_kafka_topic_name(only_rkt))); in rd_kafka_metadata()
|
| H A D | rdkafka.h | 4612 rd_kafka_topic_t *only_rkt,
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdkafka_metadata.c | 44 rd_kafka_topic_t *only_rkt,
66 if (only_rkt)
68 rd_strdup(rd_kafka_topic_name(only_rkt)));
|
| H A D | rdkafka.h | 4606 rd_kafka_topic_t *only_rkt,
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/src/ |
| H A D | bindings.rs | 1377 only_rkt: *mut rd_kafka_topic_t, in rd_kafka_metadata()
|