Add DescribeTopics and DescribeCluster support for admin client API

Cargo.toml

@@ -28,6 +28,7 @@ serde_json = "1.0.0"
 slab = "0.4"
 tokio = { version = "1.18", features = ["rt", "time"], optional = true }
 tracing = { version = "0.1.30", optional = true }
+uuid = "1.10.0"
 
 [dev-dependencies]
 async-std = { version = "1.9.0", features = ["attributes"] }

rdkafka-sys/src/types.rs

@@ -99,6 +99,18 @@ pub type RDKafkaGroupResult = bindings::rd_kafka_group_result_t;
 /// Native rdkafka mock cluster.
 pub type RDKafkaMockCluster = bindings::rd_kafka_mock_cluster_t;
 
+/// Native rdkafka topic collection.
+pub type RDKafkaTopicCollection = bindings::rd_kafka_TopicCollection_t;
+
+/// Native rdkafka node.
+pub type RDKafkaNode = bindings::rd_kafka_Node_t;
+
+/// Native rdkafka topic description.
+pub type RDKafkaTopicDescription = bindings::rd_kafka_TopicDescription_t;
+
+/// Native rdkafka topic partition info.
+pub type RDKafkaTopicPartitionInfo = bindings::rd_kafka_TopicPartitionInfo_t;
+
 // ENUMS
 
 /// Client types.
@@ -119,6 +131,15 @@ pub use bindings::rd_kafka_ResourceType_t as RDKafkaResourceType;
 /// Config source.
 pub use bindings::rd_kafka_ConfigSource_t as RDKafkaConfigSource;
 
+/// Isolation level.
+pub use bindings::rd_kafka_IsolationLevel_t as RDKafkaIsolationLevel;
+
+/// Consumer group state.
+pub use bindings::rd_kafka_consumer_group_state_t as RDKafkaConsumerGroupState;
+
+/// ACL operation.
+pub use bindings::rd_kafka_AclOperation_t as RDKafkaAclOperation;
+
 // Errors enum
 
 /// Native rdkafka error code.