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/09/01 06:45:12 UTC
[camel-kafka-connector] 01/03: Added connector.class in adoc
documentation for all connector
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch connector-class-0.4.x
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 618c4fea7c126dd9a37ee31ff5fc17073013506b
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Sep 1 08:14:23 2020 +0200
Added connector.class in adoc documentation for all connector
---
.../kafkaconnector/maven/CamelKafkaConnectorUpdateMojo.java | 5 +++--
.../camel/kafkaconnector/maven/dto/CamelKafkaConnectorModel.java | 9 +++++++++
.../src/main/resources/camel-kafka-connector-sink-options.mvel | 7 +++++++
.../src/main/resources/camel-kafka-connector-source-options.mvel | 7 +++++++
4 files changed, 26 insertions(+), 2 deletions(-)
diff --git a/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorUpdateMojo.java b/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorUpdateMojo.java
index 3310949..8c41cd8 100644
--- a/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorUpdateMojo.java
+++ b/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/CamelKafkaConnectorUpdateMojo.java
@@ -512,7 +512,7 @@ public class CamelKafkaConnectorUpdateMojo extends AbstractCamelKafkaConnectorMo
File docFile = new File(docFolder, getMainDepArtifactId() + "-kafka-" + ct.name().toLowerCase() + "-connector.adoc");
File docFolderWebsite = new File(projectBaseDir, "docs/modules/ROOT/pages/connectors/");
File docFileWebsite = new File(docFolderWebsite, getMainDepArtifactId() + "-kafka-" + ct.name().toLowerCase() + "-connector.adoc");
- String changed = templateAutoConfigurationOptions(listOptions, getMainDepArtifactId(), connectorDir, ct);
+ String changed = templateAutoConfigurationOptions(listOptions, getMainDepArtifactId(), connectorDir, ct, packageName + "." + javaClassConnectorName);
boolean updated = updateAutoConfigureOptions(docFile, changed);
if (updated) {
getLog().info("Updated doc file: " + docFile);
@@ -618,7 +618,7 @@ public class CamelKafkaConnectorUpdateMojo extends AbstractCamelKafkaConnectorMo
listOptions.add(optionModel);
}
- private String templateAutoConfigurationOptions(List<CamelKafkaConnectorOptionModel> options, String componentName, File connectorDir, ConnectorType ct)
+ private String templateAutoConfigurationOptions(List<CamelKafkaConnectorOptionModel> options, String componentName, File connectorDir, ConnectorType ct, String connectorClass)
throws MojoExecutionException {
CamelKafkaConnectorModel model = new CamelKafkaConnectorModel();
@@ -626,6 +626,7 @@ public class CamelKafkaConnectorUpdateMojo extends AbstractCamelKafkaConnectorMo
model.setArtifactId(getMainDepArtifactId());
model.setGroupId(getMainDepGroupId());
model.setVersion(getMainDepVersion());
+ model.setConnectorClass(connectorClass);
if (getMainDepArtifactId().equalsIgnoreCase("camel-coap+tcp")) {
model.setTitle("camel-coap-tcp");
} else if (getMainDepArtifactId().equalsIgnoreCase("camel-coaps+tcp")) {
diff --git a/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/dto/CamelKafkaConnectorModel.java b/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/dto/CamelKafkaConnectorModel.java
index 3b8b522..d4ade69 100644
--- a/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/dto/CamelKafkaConnectorModel.java
+++ b/tooling/camel-kafka-connector-generator-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/dto/CamelKafkaConnectorModel.java
@@ -23,6 +23,7 @@ public class CamelKafkaConnectorModel {
private String artifactId;
private String version;
private String title;
+ private String connectorClass;
private List<CamelKafkaConnectorOptionModel> options;
public List<CamelKafkaConnectorOptionModel> getOptions() {
@@ -64,4 +65,12 @@ public class CamelKafkaConnectorModel {
public void setVersion(String version) {
this.version = version;
}
+
+ public String getConnectorClass() {
+ return connectorClass;
+ }
+
+ public void setConnectorClass(String connectorClass) {
+ this.connectorClass = connectorClass;
+ }
}
diff --git a/tooling/camel-kafka-connector-generator-maven-plugin/src/main/resources/camel-kafka-connector-sink-options.mvel b/tooling/camel-kafka-connector-generator-maven-plugin/src/main/resources/camel-kafka-connector-sink-options.mvel
index 1fbc4bc..39b66b3 100644
--- a/tooling/camel-kafka-connector-generator-maven-plugin/src/main/resources/camel-kafka-connector-sink-options.mvel
+++ b/tooling/camel-kafka-connector-generator-maven-plugin/src/main/resources/camel-kafka-connector-sink-options.mvel
@@ -13,6 +13,13 @@ When using @{title}-kafka-connector as sink make sure to use the following Maven
</dependency>
----
+To use this Sink connector in Kafka connect you'll need to set the following connector.class
+
+[source,java]
+----
+connector.class=@{connectorClass}
+----
+
@if{options.isEmpty()}
The @{title} sink connector has no options.
@else{}
diff --git a/tooling/camel-kafka-connector-generator-maven-plugin/src/main/resources/camel-kafka-connector-source-options.mvel b/tooling/camel-kafka-connector-generator-maven-plugin/src/main/resources/camel-kafka-connector-source-options.mvel
index 382074a..0a01742 100644
--- a/tooling/camel-kafka-connector-generator-maven-plugin/src/main/resources/camel-kafka-connector-source-options.mvel
+++ b/tooling/camel-kafka-connector-generator-maven-plugin/src/main/resources/camel-kafka-connector-source-options.mvel
@@ -13,6 +13,13 @@ When using @{title}-kafka-connector as source make sure to use the following Mav
</dependency>
----
+To use this Source connector in Kafka connect you'll need to set the following connector.class
+
+[source,java]
+----
+connector.class=@{connectorClass}
+----
+
@if{options.isEmpty()}
The @{title} source connector has no options.
@else{}