in tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorDeleteMojo.java [48:63]
public void executeAll() throws MojoFailureException {
if (name == null || name.isEmpty()) {
throw new MojoFailureException("Connector name must be specified as the parameter");
}
if (name.startsWith("camel-")) {
name = name.substring("camel-".length());
}
if (name.endsWith(KAFKA_CONNECTORS_SUFFIX)) {
name = name.substring(0, name.length() - KAFKA_CONNECTORS_SUFFIX.length());
}
try {
deleteConnector();
} catch (Exception e) {
throw new MojoFailureException("Fail to delete connector " + name, e);
}
}