You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2020/10/14 09:18:41 UTC
[camel-kafka-connector] 01/03: Add converters,
transforms and aggregationStrategies to catalog
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch aggr-conv-transf
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 668754e2124e7fdc37c579a6961fdeb2cfd100e3
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 14 09:24:13 2020 +0200
Add converters, transforms and aggregationStrategies to catalog
---
.../kafkaconnector/maven/utils/JsonMapperKafkaConnector.java | 10 ++++++++++
1 file changed, 10 insertions(+)
diff --git a/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/utils/JsonMapperKafkaConnector.java b/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/utils/JsonMapperKafkaConnector.java
index 9f75272..992c24d 100644
--- a/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/utils/JsonMapperKafkaConnector.java
+++ b/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/utils/JsonMapperKafkaConnector.java
@@ -20,6 +20,7 @@ import java.util.List;
import org.apache.camel.kafkaconnector.model.CamelKafkaConnectorModel;
import org.apache.camel.kafkaconnector.model.CamelKafkaConnectorOptionModel;
+import org.apache.camel.util.json.JsonArray;
import org.apache.camel.util.json.JsonObject;
public final class JsonMapperKafkaConnector {
@@ -41,6 +42,15 @@ public final class JsonMapperKafkaConnector {
JsonObject wrapper = new JsonObject();
wrapper.put("connector", obj);
wrapper.put("properties", asJsonObject(model.getOptions()));
+ if (model.getConverters().size() > 0) {
+ wrapper.put("converters", new JsonArray(model.getConverters()));
+ }
+ if (model.getTransforms().size() > 0) {
+ wrapper.put("transforms", new JsonArray(model.getTransforms()));
+ }
+ if (model.getAggregationStrategies().size() > 0) {
+ wrapper.put("aggregationStrategies", new JsonArray(model.getAggregationStrategies()));
+ }
return wrapper;
}