Use Confluent 7.7 and fix tests for resetConnectorOffsets

Author: Dugong42

api/src/test/java/io/kafbat/ui/AbstractIntegrationTest.java

@@ -38,7 +38,7 @@ public abstract class AbstractIntegrationTest {
   private static final boolean IS_ARM =
       System.getProperty("os.arch").contains("arm") || System.getProperty("os.arch").contains("aarch64");
 
-  private static final String CONFLUENT_PLATFORM_VERSION = IS_ARM ? "7.2.1.arm64" : "7.2.1";
+  private static final String CONFLUENT_PLATFORM_VERSION = IS_ARM ? "7.7.1.arm64" : "7.7.1";
 
   public static final KafkaContainer kafka = new KafkaContainer(
       DockerImageName.parse("confluentinc/cp-kafka").withTag(CONFLUENT_PLATFORM_VERSION))

api/src/test/java/io/kafbat/ui/KafkaConnectServiceTests.java

@@ -411,15 +411,24 @@ public void shouldReturn400WhenTryingToCreateConnectorWithExistingName() {
 
   @Test
   public void shouldResetConnectorWhenInStoppedState() {
-    webTestClient.put()
-        .uri("/api/clusters/{clusterName}/connectors/{connectName}/connectors/{connectorName}/action/STOP", LOCAL,
-            connectName, connectorName)
+
+    webTestClient.post()
+        .uri("/api/clusters/{clusterName}/connects/{connectName}/connectors/{connectorName}/action/STOP",
+            LOCAL, connectName, connectorName)
         .exchange()
         .expectStatus().isOk();
 
+    webTestClient.get()
+        .uri("/api/clusters/{clusterName}/connects/{connectName}/connectors/{connectorName}",
+            LOCAL, connectName, connectorName)
+        .exchange()
+        .expectStatus().isOk()
+        .expectBody(ConnectorDTO.class)
+        .value(connector -> assertThat(connector.getStatus().getState()).isEqualTo(ConnectorStateDTO.STOPPED));
+
     webTestClient.delete()
-        .uri("/api/clusters/{clusterName}/connectors/{connectName}/connectors/{connectorName}/offsets", LOCAL,
-            connectName, connectorName)
+        .uri("/api/clusters/{clusterName}/connects/{connectName}/connectors/{connectorName}/offsets",
+            LOCAL, connectName, connectorName)
         .exchange()
         .expectStatus().isOk();
 
@@ -428,6 +437,14 @@ public void shouldResetConnectorWhenInStoppedState() {
   @Test
   public void shouldReturn400WhenResettingConnectorInRunningState() {
 
+    webTestClient.get()
+        .uri("/api/clusters/{clusterName}/connects/{connectName}/connectors/{connectorName}",
+            LOCAL, connectName, connectorName)
+        .exchange()
+        .expectStatus().isOk()
+        .expectBody(ConnectorDTO.class)
+        .value(connector -> assertThat(connector.getStatus().getState()).isEqualTo(ConnectorStateDTO.RUNNING));
+
     webTestClient.delete()
         .uri("/api/clusters/{clusterName}/connectors/{connectName}/connectors/{connectorName}/offsets", LOCAL,
             connectName, connectorName)