Test bad request when resetting running connector

kafbat · Nov 5, 2024 · f7f4591 · f7f4591
1 parent e52d6cc
commit f7f4591
Showing 1 changed file with 12 additions and 1 deletion.
diff --git a/api/src/test/java/io/kafbat/ui/KafkaConnectServiceTests.java b/api/src/test/java/io/kafbat/ui/KafkaConnectServiceTests.java
@@ -408,7 +408,7 @@ public void shouldReturn400WhenTryingToCreateConnectorWithExistingName() {
         .expectStatus()
         .isBadRequest();
   }
-    
+
   @Test
   public void shouldResetConnectorWhenInStoppedState() {
     webTestClient.put()
@@ -424,4 +424,15 @@ public void shouldResetConnectorWhenInStoppedState() {
         .expectStatus().isOk();
 
   }
+
+  @Test
+  public void shouldReturn400WhenResettingConnectorInRunningState() {
+
+    webTestClient.delete()
+        .uri("/api/clusters/{clusterName}/connectors/{connectName}/connectors/{connectorName}/offsets", LOCAL,
+            connectName, connectorName)
+        .exchange()
+        .expectStatus().isBadRequest();
+
+  }
 }