fix: test_consumer_group_action_mixed_results

Author: j7nw4r

tests/admin.rs

@@ -638,28 +638,4 @@ async fn test_groups() {
         .await
         .expect("could not create admin client");
     let opts = AdminOptions::new();
-
-    // Verify that deleting a valid and invalid group results in a mixed result
-    // set.
-    {
-        let group_name = rand_test_group();
-        let unknown_group_name = rand_test_group();
-        create_consumer_group(&group_name).await;
-        let res = admin_client
-            .delete_groups(
-                &[&group_name, &unknown_group_name],
-                &AdminOptions::default(),
-            )
-            .await;
-        assert_eq!(
-            res,
-            Ok(vec![
-                Ok(group_name.to_string()),
-                Err((
-                    unknown_group_name.to_string(),
-                    RDKafkaErrorCode::GroupIdNotFound
-                ))
-            ])
-        );
-    }
 }

tests/consumer_groups.rs

@@ -1,3 +1,4 @@
+use crate::utils::consumer;
 use crate::utils::containers::KafkaContext;
 use crate::utils::logging::init_test_logger;
 use crate::utils::rand::{rand_test_group, rand_test_topic};
@@ -57,7 +58,7 @@ pub async fn test_consumer_groups_deletion() {
 /// Verify that attempting to delete an unknown group returns a "group not
 /// found" error.
 #[tokio::test]
-pub async fn delete_unknown_group() {
+pub async fn test_delete_unknown_group() {
     init_test_logger();
 
     // Get Kafka container context.
@@ -77,3 +78,64 @@ pub async fn delete_unknown_group() {
     let expected: GroupResult = Err((unknown_group_name, RDKafkaErrorCode::NotCoordinator));
     assert_eq!(res, Ok(vec![expected]));
 }
+
+/// Verify that deleting a valid and invalid group results in a mixed result
+/// set.
+#[tokio::test]
+pub async fn test_consumer_group_action_mixed_results() {
+    init_test_logger();
+
+    // Get Kafka container context.
+    let kafka_context = KafkaContext::shared()
+        .await
+        .expect("could not create kafka context");
+
+    // Create admin client
+    let admin_client = utils::admin::create_admin_client(&kafka_context.bootstrap_servers)
+        .await
+        .expect("could not create admin client");
+
+    // Create consumer_client
+    let group_name = rand_test_group();
+    let topic_name = rand_test_topic("test_topic");
+    let consumer_client = utils::consumer::create_unsubscribed_base_consumer(
+        &kafka_context.bootstrap_servers,
+        Some(&group_name),
+    )
+    .await
+    .expect("could not create subscribed base consumer");
+
+    admin_client
+        .create_topics(
+            &[NewTopic {
+                name: &topic_name,
+                num_partitions: 1,
+                replication: TopicReplication::Fixed(1),
+                config: vec![],
+            }],
+            &AdminOptions::default(),
+        )
+        .await
+        .expect("topic creation failed");
+
+    let unknown_group_name = rand_test_group();
+    consumer::create_consumer_group_on_topic(&consumer_client, &topic_name)
+        .await
+        .expect("could not create group");
+    let res = admin_client
+        .delete_groups(
+            &[&group_name, &unknown_group_name],
+            &AdminOptions::default(),
+        )
+        .await;
+    assert_eq!(
+        res,
+        Ok(vec![
+            Ok(group_name.to_string()),
+            Err((
+                unknown_group_name.to_string(),
+                RDKafkaErrorCode::GroupIdNotFound
+            ))
+        ])
+    );
+}