Skip to content

Commit e8e4347

Browse files
committed
tests: reset stopped connector
1 parent 951b8c3 commit e8e4347

File tree

1 file changed

+16
-0
lines changed

1 file changed

+16
-0
lines changed

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

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -408,4 +408,20 @@ public void shouldReturn400WhenTryingToCreateConnectorWithExistingName() {
408408
.expectStatus()
409409
.isBadRequest();
410410
}
411+
412+
@Test
413+
public void shouldResetConnectorWhenInStoppedState() {
414+
webTestClient.put()
415+
.uri("/api/clusters/{clusterName}/connectors/{connectName}/connectors/{connectorName}/action/STOP", LOCAL,
416+
connectName, connectorName)
417+
.exchange()
418+
.expectStatus().isOk();
419+
420+
webTestClient.delete()
421+
.uri("/api/clusters/{clusterName}/connectors/{connectName}/connectors/{connectorName}/offsets", LOCAL,
422+
connectName, connectorName)
423+
.exchange()
424+
.expectStatus().isOk();
425+
426+
}
411427
}

0 commit comments

Comments
 (0)