Skip to content

Commit c3f98b0

Browse files
committed
Fixed checkstyle
1 parent f3f58f0 commit c3f98b0

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

api/src/main/java/io/kafbat/ui/service/KafkaConnectService.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,7 @@ public Flux<ConnectDTO> getConnects(KafkaCluster cluster, boolean withStats) {
7272

7373
if (withStats) {
7474
return connectClusters.map(connects ->
75-
Flux.fromIterable(connects).flatMap( c ->
75+
Flux.fromIterable(connects).flatMap(c ->
7676
getClusterInfo(cluster, c.getName()).map(ci -> Tuples.of(c, ci))
7777
).flatMap(tuple -> (
7878
getConnectConnectorsFromCache(new ConnectCacheKey(cluster, tuple.getT1()))

0 commit comments

Comments
 (0)