Add delete_groups API to AdminClient. (no-op in simulation)

madsim-rdkafka/CHANGELOG.md

@@ -6,6 +6,12 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+## [0.4.3] - 2025-01-09
+
+### Changed
+
+- Add `delete_groups` API to `AdminClient`. (no-op in simulation)
+
 ## [0.4.2] - 2024-05-13
 
 ### Changed

madsim-rdkafka/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "madsim-rdkafka"
-version = "0.4.2+0.34.0"
+version = "0.4.3+0.34.0"
 edition = "2021"
 authors = ["Runji Wang <wangrunji0408@163.com>"]
 description = "The rdkafka simulator on madsim."

madsim-rdkafka/src/sim/admin.rs

@@ -20,6 +20,7 @@
 // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 // SOFTWARE.
 
+use std::future::Future;
 use std::net::SocketAddr;
 
 use madsim::net::Endpoint;
@@ -99,6 +100,16 @@ where
         }
         Ok(results)
     }
+
+    /// Deletes the named groups.
+    pub fn delete_groups(
+        &self,
+        _group_names: &[&str],
+        _opts: &AdminOptions,
+    ) -> impl Future<Output = KafkaResult<Vec<GroupResult>>> {
+        // no-op
+        std::future::ready(Ok(vec![]))
+    }
 }
 
 /// Options for an admin API request.
@@ -229,6 +240,9 @@ pub enum TopicReplication<'a> {
 /// CreatePartition operation.
 pub type TopicResult = Result<String, (String, RDKafkaErrorCode)>;
 
+/// The result of a DeleteGroup operation.
+pub type GroupResult = Result<String, (String, RDKafkaErrorCode)>;
+
 /// AdminClient configs.
 ///
 /// <https://kafka.apache.org/documentation/#adminclientconfigs>

madsim-rdkafka/src/std/admin.rs

@@ -867,7 +867,7 @@ impl<'a> NewPartitions<'a> {
 
     /// Sets the partition replica assignment for the new partitions. Only
     /// assignments for newly created replicas should be included.
-    pub fn assign(mut self, assignment: PartitionAssignment<'a>) -> NewPartitions<'_> {
+    pub fn assign(mut self, assignment: PartitionAssignment<'a>) -> NewPartitions<'a> {
         self.assignment = Some(assignment);
         self
     }