Skip to content

Commit 04f0e67

Browse files
committed
BE: issue #1090 added topics connect endpoint
1 parent 94cbe87 commit 04f0e67

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,7 @@ void setUp() {
8888
webTestClient.post()
8989
.uri("/api/clusters/{clusterName}/connects/{connectName}/connectors", LOCAL, connectName)
9090
.bodyValue(new NewConnectorDTO()
91-
.name(connectorName+"source")
91+
.name(connectorName + "source")
9292
.config(Map.of(
9393
"connector.class", "org.apache.kafka.connect.file.FileStreamSourceConnector",
9494
"tasks.max", "1",
@@ -111,7 +111,7 @@ void tearDown() {
111111
.expectStatus().isOk();
112112
webTestClient.delete()
113113
.uri("/api/clusters/{clusterName}/connects/{connectName}/connectors/{connectorName}", LOCAL,
114-
connectName, connectorName+"source")
114+
connectName, connectorName + "source")
115115
.exchange()
116116
.expectStatus().isOk();
117117
}

0 commit comments

Comments
 (0)