Catalog API: Fixed CS
@@ -39,10 +39,9 @@ import org.slf4j.LoggerFactory;
public class CamelKafkaConnectorCatalog {
- private static final Logger LOG = LoggerFactory.getLogger(CamelKafkaConnectorCatalog.class);
-
static List<String> connectorsName = new ArrayList<String>();
static Map<String, CamelKafkaConnectorModel> connectorsModel = new HashMap<String, CamelKafkaConnectorModel>();
+ private static final Logger LOG = LoggerFactory.getLogger(CamelKafkaConnectorCatalog.class);
public CamelKafkaConnectorCatalog() {
initCatalog();
@@ -84,8 +83,9 @@ public class CamelKafkaConnectorCatalog {
public String getConnectorAsJson(String connectorName) {
String result = null;
try {
- result = Files.lines(Paths.get("src/generated/resources/connectors/" + connectorName + ".json"))
- .parallel() // for parallel processing
+ result = Files.lines(Paths.get("src/generated/resources/connectors/" + connectorName + ".json")).parallel() // for
+ // parallel
+ // processing
.map(String::trim) // to change line
.collect(Collectors.joining());
} catch (IOException e) {
