in tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/utils/JsonMapperKafkaConnector.java [34:56]
public static JsonObject asJsonObject(CamelKafkaConnectorModel model) {
JsonObject obj = new JsonObject();
obj.put("class", model.getConnectorClass());
obj.put("artifactId", model.getArtifactId() + KAFKA_CONNECTOR_ARTIFACTID_SUFFIX);
obj.put("groupId", model.getGroupId() + KAFKA_CONNECTOR_GROUPID_SUFFIX);
obj.put("id", model.getTitle() + "-" + model.getType());
obj.put("type", model.getType());
obj.put("version", model.getVersion());
obj.put("description", model.getDescription());
JsonObject wrapper = new JsonObject();
wrapper.put("connector", obj);
wrapper.put("properties", asJsonObject(model.getOptions()));
if (!model.getConverters().isEmpty()) {
wrapper.put("converters", new JsonArray(model.getConverters()));
}
if (!model.getTransforms().isEmpty()) {
wrapper.put("transforms", new JsonArray(model.getTransforms()));
}
if (!model.getAggregationStrategies().isEmpty()) {
wrapper.put("aggregationStrategies", new JsonArray(model.getAggregationStrategies()));
}
return wrapper;
}