Skip to content

Commit 2ec9897

Browse files
committed
chore(bump): bump java version to 21
- kafka client: 3.3.1 -> 3.8.0 - aspectj: 1.9.9.1 -> 1.9.21 Maven Plugins: - clean: 3.2.0 -> 3.4.0 - compile: 3.10.1 -> 3.13.0 - resources: 3.2.0 -> 3.3.1 - surefire: 3.1.2 -> 3.5.1 - openapi generator : 6.6.0 -> 7.9.0 - springdoc openapi webflux: 1.2.32 -> 1.8.0 - surefire: 3.2.3 -> 3.5.1 (for e2e tests) - surefire-ng: 3.2.5 -> 3.5.1 (for e2e tests)
1 parent fa558d2 commit 2ec9897

File tree

1 file changed

+0
-11
lines changed

1 file changed

+0
-11
lines changed

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

Lines changed: 0 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
package io.kafbat.ui.service;
22

3-
import com.fasterxml.jackson.core.type.TypeReference;
43
import com.fasterxml.jackson.databind.ObjectMapper;
54
import io.kafbat.ui.connect.api.KafkaConnectClientApi;
65
import io.kafbat.ui.connect.model.ConnectorStatus;
@@ -31,7 +30,6 @@
3130
import java.util.stream.Stream;
3231
import javax.annotation.Nullable;
3332
import lombok.RequiredArgsConstructor;
34-
import lombok.SneakyThrows;
3533
import lombok.extern.slf4j.Slf4j;
3634
import org.apache.commons.lang3.StringUtils;
3735
import org.springframework.stereotype.Service;
@@ -107,9 +105,6 @@ public Mono<ConnectorTopics> getConnectorTopics(KafkaCluster cluster, String con
107105
public Flux<String> getConnectorNames(KafkaCluster cluster, String connectName) {
108106
return api(cluster, connectName)
109107
.mono(client -> client.getConnectors(null))
110-
// for some reason `getConnectors` method returns the response as a single string
111-
.map(List::getFirst)
112-
.map(this::parseConnectorsNamesStringToList)
113108
.flatMapMany(Flux::fromIterable);
114109
}
115110

@@ -118,12 +113,6 @@ public Flux<String> getConnectorNamesWithErrorsSuppress(KafkaCluster cluster, St
118113
return getConnectorNames(cluster, connectName).onErrorComplete();
119114
}
120115

121-
@SneakyThrows
122-
private List<String> parseConnectorsNamesStringToList(String json) {
123-
return objectMapper.readValue(json, new TypeReference<>() {
124-
});
125-
}
126-
127116
public Mono<ConnectorDTO> createConnector(KafkaCluster cluster, String connectName,
128117
Mono<NewConnectorDTO> connector) {
129118
return api(cluster, connectName)

0 commit comments

Comments
 (0)