You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by va...@apache.org on 2020/05/08 22:14:28 UTC
[camel-kafka-connector] branch master updated (f52aff2 -> 0f3193a)
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.
from f52aff2 Fixed nav with basic concepts
new b39ea20 Attempt to remove some Thread.sleep() in tests see #186
new a54fa69 Ordered the component list by name in order to change only if components are added or removed.
new 0f3193a chore: regen doc.
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../camel/kafkaconnector/CamelSourceTaskTest.java | 69 ++++++++-----------
.../camel/kafkaconnector/utils/TaskHelperTest.java | 14 ++--
docs/modules/ROOT/pages/connectors.adoc | 80 +++++++++++-----------
.../maven/docs/UpdateDocComponentsListMojo.java | 22 +++---
.../docs/dto/CamelKafkaConnectorTableModel.java | 8 +--
5 files changed, 92 insertions(+), 101 deletions(-)
[camel-kafka-connector] 01/03: Attempt to remove some
Thread.sleep() in tests see #186
Posted by va...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit b39ea20ffac05ac237d8a39fd8af91f1f5df0986
Author: Andrea Tarocchi <an...@gmail.com>
AuthorDate: Fri May 8 23:30:16 2020 +0200
Attempt to remove some Thread.sleep() in tests see #186
---
.../camel/kafkaconnector/CamelSourceTaskTest.java | 69 +++++++++-------------
.../camel/kafkaconnector/utils/TaskHelperTest.java | 14 ++---
2 files changed, 36 insertions(+), 47 deletions(-)
diff --git a/core/src/test/java/org/apache/camel/kafkaconnector/CamelSourceTaskTest.java b/core/src/test/java/org/apache/camel/kafkaconnector/CamelSourceTaskTest.java
index 2f02d68..2934a3b 100644
--- a/core/src/test/java/org/apache/camel/kafkaconnector/CamelSourceTaskTest.java
+++ b/core/src/test/java/org/apache/camel/kafkaconnector/CamelSourceTaskTest.java
@@ -31,7 +31,6 @@ import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNull;
import static org.junit.jupiter.api.Assertions.assertTrue;
-import static org.junit.jupiter.api.Assertions.fail;
public class CamelSourceTaskTest {
@@ -79,9 +78,7 @@ public class CamelSourceTaskTest {
// first we test if we have a key in the message with body
template.sendBodyAndHeader("direct:start", "awesome!", "CamelSpecialTestKey", 1234);
- Thread.sleep(11L);
-
- List<SourceRecord> poll = camelSourceTask.poll();
+ List<SourceRecord> poll = camelSourceTaskPollWithRetries(camelSourceTask, 3);
assertEquals(1, poll.size());
assertEquals(1234, poll.get(0).key());
assertEquals(Schema.Type.INT32, poll.get(0).keySchema().type());
@@ -89,9 +86,7 @@ public class CamelSourceTaskTest {
// second we test if we have no key under the header
template.sendBodyAndHeader("direct:start", "awesome!", "WrongHeader", 1234);
- Thread.sleep(11L);
-
- poll = camelSourceTask.poll();
+ poll = camelSourceTaskPollWithRetries(camelSourceTask, 3);
assertEquals(1, poll.size());
assertNull(poll.get(0).key());
assertNull(poll.get(0).keySchema());
@@ -99,9 +94,7 @@ public class CamelSourceTaskTest {
// third we test if we have the header but with null value
template.sendBodyAndHeader("direct:start", "awesome!", "CamelSpecialTestKey", null);
- Thread.sleep(10L);
-
- camelSourceTask.poll();
+ poll = camelSourceTaskPollWithRetries(camelSourceTask, 3);
assertEquals(1, poll.size());
assertNull(poll.get(0).key());
assertNull(poll.get(0).keySchema());
@@ -123,9 +116,7 @@ public class CamelSourceTaskTest {
// send first data
template.sendBody("direct:start", "testing kafka connect");
- Thread.sleep(11L);
-
- List<SourceRecord> poll = camelSourceTask.poll();
+ List<SourceRecord> poll = camelSourceTaskPollWithRetries(camelSourceTask, 5);
assertEquals(1, poll.size());
assertEquals("testing kafka connect", poll.get(0).value());
assertEquals(Schema.Type.STRING, poll.get(0).valueSchema().type());
@@ -135,9 +126,7 @@ public class CamelSourceTaskTest {
// send second data
template.sendBody("direct:start", true);
- Thread.sleep(11L);
-
- poll = camelSourceTask.poll();
+ poll = camelSourceTaskPollWithRetries(camelSourceTask, 5);
assertEquals(1, poll.size());
assertTrue((boolean)poll.get(0).value());
assertEquals(Schema.Type.BOOLEAN, poll.get(0).valueSchema().type());
@@ -147,9 +136,7 @@ public class CamelSourceTaskTest {
// second third data
template.sendBody("direct:start", 1234L);
- Thread.sleep(10L);
-
- poll = camelSourceTask.poll();
+ poll = camelSourceTaskPollWithRetries(camelSourceTask, 5);
assertEquals(1, poll.size());
assertEquals(1234L, poll.get(0).value());
assertEquals(Schema.Type.INT64, poll.get(0).valueSchema().type());
@@ -159,8 +146,7 @@ public class CamelSourceTaskTest {
// third with null data
template.sendBody("direct:start", null);
- Thread.sleep(10L);
- poll = camelSourceTask.poll();
+ poll = camelSourceTaskPollWithRetries(camelSourceTask, 5);
assertNull(poll.get(0).key());
assertNull(poll.get(0).keySchema());
assertNull(poll.get(0).value());
@@ -179,26 +165,14 @@ public class CamelSourceTaskTest {
CamelSourceTask camelSourceTask = new CamelSourceTask();
camelSourceTask.start(props);
- long sleepTime = 30L;
- Thread.sleep(sleepTime);
- List<SourceRecord> poll;
- int retries = 3;
- do {
- poll = camelSourceTask.poll();
- if (poll == null) {
- retries--;
- if (retries == 0) {
- fail("Exhausted the maximum retries and no record was returned");
- }
- Thread.sleep(sleepTime);
- }
- } while (poll == null && retries > 0);
-
- assertTrue(poll.size() >= 1, "Received messages are: " + poll.size() + ", expected between 1 and 2.");
- assertTrue(poll.size() <= 2, "Received messages are: " + poll.size() + ", expected between 1 and 2.");
+ List<SourceRecord> poll = camelSourceTaskPollWithRetries(camelSourceTask, 3);
camelSourceTask.stop();
+
+ assertTrue(poll.size() >= 0 && poll.size() <= 1, "Received messages are: " + poll.size() + ", expected between 0 and 1.");
}
+
+
@Test
public void testSourcePollingMaxRecordNumber() throws InterruptedException {
Map<String, String> props = new HashMap<>();
@@ -209,11 +183,10 @@ public class CamelSourceTaskTest {
CamelSourceTask camelSourceTask = new CamelSourceTask();
camelSourceTask.start(props);
- Thread.sleep(11L);
List<SourceRecord> poll = camelSourceTask.poll();
camelSourceTask.stop();
- assertEquals(1, poll.size());
+ assertTrue(poll.size() >= 0 && poll.size() <= 1, "Received messages are: " + poll.size() + ", expected between 0 and 1.");
}
@Test
@@ -331,4 +304,20 @@ public class CamelSourceTaskTest {
camelSourceTask.stop();
}
+
+ private List<SourceRecord> camelSourceTaskPollWithRetries(CamelSourceTask camelSourceTask, int retries) throws InterruptedException {
+ return camelSourceTaskPollWithRetries(camelSourceTask, retries, 0L);
+ }
+
+ private List<SourceRecord> camelSourceTaskPollWithRetries(CamelSourceTask camelSourceTask, int retries, long sleepBetweenRetires) throws InterruptedException {
+ List<SourceRecord> poll;
+ do {
+ poll = camelSourceTask.poll();
+ if (poll == null) {
+ retries--;
+ }
+ Thread.sleep(sleepBetweenRetires);
+ } while (poll == null && retries > 0);
+ return poll;
+ }
}
diff --git a/core/src/test/java/org/apache/camel/kafkaconnector/utils/TaskHelperTest.java b/core/src/test/java/org/apache/camel/kafkaconnector/utils/TaskHelperTest.java
index ea6938d..3cfe5ed 100644
--- a/core/src/test/java/org/apache/camel/kafkaconnector/utils/TaskHelperTest.java
+++ b/core/src/test/java/org/apache/camel/kafkaconnector/utils/TaskHelperTest.java
@@ -185,21 +185,21 @@ public class TaskHelperTest {
DefaultCamelContext dcc = new DefaultCamelContext();
RuntimeCamelCatalog rcc = dcc.adapt(ExtendedCamelContext.class).getRuntimeCamelCatalog();
Map<String, String> props = new HashMap<String, String>() {{
- put("prefix.name", "test");
- put("anotherPrefix.synchronous", "true");
+ put("camel.source.path.name", "test");
+ put("camel.source.endpoint.synchronous", "true");
}};
- String result = TaskHelper.buildUrl(rcc, props, "direct", "prefix.", "anotherPrefix.");
+ String result = TaskHelper.buildUrl(rcc, props, "direct", "camel.source.endpoint.", "camel.source.path.");
assertEquals("direct:test?synchronous=true", result);
props = new HashMap<String, String>() {{
- put("prefix.port", "8080");
- put("anotherPrefix.keyspace", "test");
- put("anotherPrefix.hosts", "localhost");
+ put("camel.source.path.port", "8080");
+ put("camel.source.path.keyspace", "test");
+ put("camel.source.path.hosts", "localhost");
}};
- result = TaskHelper.buildUrl(rcc, props, "cql", "prefix.", "anotherPrefix.");
+ result = TaskHelper.buildUrl(rcc, props, "cql", "camel.source.endpoint.", "camel.source.path.");
assertEquals("cql:localhost:8080/test", result);
}
[camel-kafka-connector] 03/03: chore: regen doc.
Posted by va...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 0f3193adc8785c7f5bb1d623b4966ec111c2312d
Author: Andrea Tarocchi <an...@gmail.com>
AuthorDate: Fri May 8 23:44:58 2020 +0200
chore: regen doc.
---
docs/modules/ROOT/pages/connectors.adoc | 80 ++++++++++++++++-----------------
1 file changed, 40 insertions(+), 40 deletions(-)
diff --git a/docs/modules/ROOT/pages/connectors.adoc b/docs/modules/ROOT/pages/connectors.adoc
index da28c1f..616b859 100644
--- a/docs/modules/ROOT/pages/connectors.adoc
+++ b/docs/modules/ROOT/pages/connectors.adoc
@@ -32,8 +32,8 @@ Number of Camel Kafka connectors: 344
| *camel-aws-ecs-kafka-connector* | true | false | xref:connectors/camel-aws-ecs-kafka-sink-connector.adoc[Sink Docs] |
| *camel-aws-eks-kafka-connector* | true | false | xref:connectors/camel-aws-eks-kafka-sink-connector.adoc[Sink Docs] |
| *camel-aws-iam-kafka-connector* | true | false | xref:connectors/camel-aws-iam-kafka-sink-connector.adoc[Sink Docs] |
-| *camel-aws-kinesis-kafka-connector* | true | true | xref:connectors/camel-aws-kinesis-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-aws-kinesis-kafka-source-connector.adoc[Source Docs]
| *camel-aws-kinesis-firehose-kafka-connector* | true | false | xref:connectors/camel-aws-kinesis-firehose-kafka-sink-connector.adoc[Sink Docs] |
+| *camel-aws-kinesis-kafka-connector* | true | true | xref:connectors/camel-aws-kinesis-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-aws-kinesis-kafka-source-connector.adoc[Source Docs]
| *camel-aws-kms-kafka-connector* | true | false | xref:connectors/camel-aws-kms-kafka-sink-connector.adoc[Sink Docs] |
| *camel-aws-lambda-kafka-connector* | true | false | xref:connectors/camel-aws-lambda-kafka-sink-connector.adoc[Sink Docs] |
| *camel-aws-mq-kafka-connector* | true | false | xref:connectors/camel-aws-mq-kafka-sink-connector.adoc[Sink Docs] |
@@ -88,8 +88,8 @@ Number of Camel Kafka connectors: 344
| *camel-couchdb-kafka-connector* | true | true | xref:connectors/camel-couchdb-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-couchdb-kafka-source-connector.adoc[Source Docs]
| *camel-cql-kafka-connector* | true | true | xref:connectors/camel-cql-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-cql-kafka-source-connector.adoc[Source Docs]
| *camel-cron-kafka-connector* | false | true | | xref:connectors/camel-cron-kafka-source-connector.adoc[Source Docs]
-| *camel-crypto-kafka-connector* | true | false | xref:connectors/camel-crypto-kafka-sink-connector.adoc[Sink Docs] |
| *camel-crypto-cms-kafka-connector* | true | false | xref:connectors/camel-crypto-cms-kafka-sink-connector.adoc[Sink Docs] |
+| *camel-crypto-kafka-connector* | true | false | xref:connectors/camel-crypto-kafka-sink-connector.adoc[Sink Docs] |
| *camel-cxf-kafka-connector* | true | true | xref:connectors/camel-cxf-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-cxf-kafka-source-connector.adoc[Source Docs]
| *camel-cxfrs-kafka-connector* | true | true | xref:connectors/camel-cxfrs-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-cxfrs-kafka-source-connector.adoc[Source Docs]
| *camel-dataformat-kafka-connector* | true | false | xref:connectors/camel-dataformat-kafka-sink-connector.adoc[Sink Docs] |
@@ -171,8 +171,8 @@ Number of Camel Kafka connectors: 344
| *camel-ignite-idgen-kafka-connector* | true | false | xref:connectors/camel-ignite-idgen-kafka-sink-connector.adoc[Sink Docs] |
| *camel-ignite-messaging-kafka-connector* | true | true | xref:connectors/camel-ignite-messaging-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-ignite-messaging-kafka-source-connector.adoc[Source Docs]
| *camel-ignite-queue-kafka-connector* | true | false | xref:connectors/camel-ignite-queue-kafka-sink-connector.adoc[Sink Docs] |
-| *camel-imap-kafka-connector* | true | true | xref:connectors/camel-imap-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-imap-kafka-source-connector.adoc[Source Docs]
| *camel-ignite-set-kafka-connector* | true | false | xref:connectors/camel-ignite-set-kafka-sink-connector.adoc[Sink Docs] |
+| *camel-imap-kafka-connector* | true | true | xref:connectors/camel-imap-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-imap-kafka-source-connector.adoc[Source Docs]
| *camel-imaps-kafka-connector* | true | true | xref:connectors/camel-imaps-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-imaps-kafka-source-connector.adoc[Source Docs]
| *camel-infinispan-kafka-connector* | true | true | xref:connectors/camel-infinispan-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-infinispan-kafka-source-connector.adoc[Source Docs]
| *camel-influxdb-kafka-connector* | true | false | xref:connectors/camel-influxdb-kafka-sink-connector.adoc[Sink Docs] |
@@ -205,8 +205,8 @@ Number of Camel Kafka connectors: 344
| *camel-kubernetes-job-kafka-connector* | true | true | xref:connectors/camel-kubernetes-job-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-kubernetes-job-kafka-source-connector.adoc[Source Docs]
| *camel-kubernetes-namespaces-kafka-connector* | true | true | xref:connectors/camel-kubernetes-namespaces-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-kubernetes-namespaces-kafka-source-connector.adoc[Source Docs]
| *camel-kubernetes-nodes-kafka-connector* | true | true | xref:connectors/camel-kubernetes-nodes-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-kubernetes-nodes-kafka-source-connector.adoc[Source Docs]
-| *camel-kubernetes-persistent-volumes-kafka-connector* | true | false | xref:connectors/camel-kubernetes-persistent-volumes-kafka-sink-connector.adoc[Sink Docs] |
| *camel-kubernetes-persistent-volumes-claims-kafka-connector* | true | false | xref:connectors/camel-kubernetes-persistent-volumes-claims-kafka-sink-connector.adoc[Sink Docs] |
+| *camel-kubernetes-persistent-volumes-kafka-connector* | true | false | xref:connectors/camel-kubernetes-persistent-volumes-kafka-sink-connector.adoc[Sink Docs] |
| *camel-kubernetes-pods-kafka-connector* | true | true | xref:connectors/camel-kubernetes-pods-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-kubernetes-pods-kafka-source-connector.adoc[Source Docs]
| *camel-kubernetes-replication-controllers-kafka-connector* | true | true | xref:connectors/camel-kubernetes-replication-controllers-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-kubernetes-replication-controllers-kafka-source-connector.adoc[Source Docs]
| *camel-kubernetes-resources-quota-kafka-connector* | true | false | xref:connectors/camel-kubernetes-resources-quota-kafka-sink-connector.adoc[Sink Docs] |
@@ -230,17 +230,17 @@ Number of Camel Kafka connectors: 344
| *camel-mina-kafka-connector* | true | true | xref:connectors/camel-mina-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-mina-kafka-source-connector.adoc[Source Docs]
| *camel-mllp-kafka-connector* | true | true | xref:connectors/camel-mllp-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-mllp-kafka-source-connector.adoc[Source Docs]
| *camel-mock-kafka-connector* | true | false | xref:connectors/camel-mock-kafka-sink-connector.adoc[Sink Docs] |
-| *camel-mongodb-kafka-connector* | true | true | xref:connectors/camel-mongodb-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-mongodb-kafka-source-connector.adoc[Source Docs]
| *camel-mongodb-gridfs-kafka-connector* | true | true | xref:connectors/camel-mongodb-gridfs-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-mongodb-gridfs-kafka-source-connector.adoc[Source Docs]
+| *camel-mongodb-kafka-connector* | true | true | xref:connectors/camel-mongodb-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-mongodb-kafka-source-connector.adoc[Source Docs]
| *camel-msv-kafka-connector* | true | false | xref:connectors/camel-msv-kafka-sink-connector.adoc[Sink Docs] |
| *camel-mustache-kafka-connector* | true | false | xref:connectors/camel-mustache-kafka-sink-connector.adoc[Sink Docs] |
| *camel-mvel-kafka-connector* | true | false | xref:connectors/camel-mvel-kafka-sink-connector.adoc[Sink Docs] |
-| *camel-mybatis-kafka-connector* | true | true | xref:connectors/camel-mybatis-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-mybatis-kafka-source-connector.adoc[Source Docs]
| *camel-mybatis-bean-kafka-connector* | true | false | xref:connectors/camel-mybatis-bean-kafka-sink-connector.adoc[Sink Docs] |
+| *camel-mybatis-kafka-connector* | true | true | xref:connectors/camel-mybatis-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-mybatis-kafka-source-connector.adoc[Source Docs]
| *camel-nagios-kafka-connector* | true | false | xref:connectors/camel-nagios-kafka-sink-connector.adoc[Sink Docs] |
| *camel-nats-kafka-connector* | true | true | xref:connectors/camel-nats-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-nats-kafka-source-connector.adoc[Source Docs]
-| *camel-netty-kafka-connector* | true | true | xref:connectors/camel-netty-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-netty-kafka-source-connector.adoc[Source Docs]
| *camel-netty-http-kafka-connector* | true | true | xref:connectors/camel-netty-http-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-netty-http-kafka-source-connector.adoc[Source Docs]
+| *camel-netty-kafka-connector* | true | true | xref:connectors/camel-netty-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-netty-kafka-source-connector.adoc[Source Docs]
| *camel-nitrite-kafka-connector* | true | true | xref:connectors/camel-nitrite-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-nitrite-kafka-source-connector.adoc[Source Docs]
| *camel-nsq-kafka-connector* | true | true | xref:connectors/camel-nsq-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-nsq-kafka-source-connector.adoc[Source Docs]
| *camel-olingo2-kafka-connector* | true | true | xref:connectors/camel-olingo2-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-olingo2-kafka-source-connector.adoc[Source Docs]
@@ -257,37 +257,6 @@ Number of Camel Kafka connectors: 344
| *camel-paho-kafka-connector* | true | true | xref:connectors/camel-paho-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-paho-kafka-source-connector.adoc[Source Docs]
| *camel-paxlogging-kafka-connector* | false | true | | xref:connectors/camel-paxlogging-kafka-source-connector.adoc[Source Docs]
| *camel-pdf-kafka-connector* | true | false | xref:connectors/camel-pdf-kafka-sink-connector.adoc[Sink Docs] |
-| *camel-xquery-kafka-connector* | true | true | xref:connectors/camel-xquery-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-xquery-kafka-source-connector.adoc[Source Docs]
-| *camel-xslt-kafka-connector* | true | false | xref:connectors/camel-xslt-kafka-sink-connector.adoc[Sink Docs] |
-| *camel-xslt-saxon-kafka-connector* | true | false | xref:connectors/camel-xslt-saxon-kafka-sink-connector.adoc[Sink Docs] |
-| *camel-yammer-kafka-connector* | true | true | xref:connectors/camel-yammer-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-yammer-kafka-source-connector.adoc[Source Docs]
-| *camel-zendesk-kafka-connector* | true | true | xref:connectors/camel-zendesk-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-zendesk-kafka-source-connector.adoc[Source Docs]
-| *camel-zookeeper-kafka-connector* | true | true | xref:connectors/camel-zookeeper-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-zookeeper-kafka-source-connector.adoc[Source Docs]
-| *camel-zookeeper-master-kafka-connector* | false | true | | xref:connectors/camel-zookeeper-master-kafka-source-connector.adoc[Source Docs]
-| *camel-smtp-kafka-connector* | true | true | xref:connectors/camel-smtp-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-smtp-kafka-source-connector.adoc[Source Docs]
-| *camel-snmp-kafka-connector* | true | true | xref:connectors/camel-snmp-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-snmp-kafka-source-connector.adoc[Source Docs]
-| *camel-solrcloud-kafka-connector* | true | false | xref:connectors/camel-solrCloud-kafka-sink-connector.adoc[Sink Docs] |
-| *camel-soroush-kafka-connector* | true | true | xref:connectors/camel-soroush-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-soroush-kafka-source-connector.adoc[Source Docs]
-| *camel-spark-rest-kafka-connector* | false | true | | xref:connectors/camel-spark-rest-kafka-source-connector.adoc[Source Docs]
-| *camel-spring-batch-kafka-connector* | true | false | xref:connectors/camel-spring-batch-kafka-sink-connector.adoc[Sink Docs] |
-| *camel-spring-integration-kafka-connector* | true | true | xref:connectors/camel-spring-integration-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-spring-integration-kafka-source-connector.adoc[Source Docs]
-| *camel-spring-redis-kafka-connector* | true | true | xref:connectors/camel-spring-redis-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-spring-redis-kafka-source-connector.adoc[Source Docs]
-| *camel-sql-kafka-connector* | true | true | xref:connectors/camel-sql-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-sql-kafka-source-connector.adoc[Source Docs]
-| *camel-ssh-kafka-connector* | true | true | xref:connectors/camel-ssh-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-ssh-kafka-source-connector.adoc[Source Docs]
-| *camel-stomp-kafka-connector* | true | true | xref:connectors/camel-stomp-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-stomp-kafka-source-connector.adoc[Source Docs]
-| *camel-string-template-kafka-connector* | true | false | xref:connectors/camel-string-template-kafka-sink-connector.adoc[Sink Docs] |
-| *camel-thrift-kafka-connector* | true | true | xref:connectors/camel-thrift-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-thrift-kafka-source-connector.adoc[Source Docs]
-| *camel-timer-kafka-connector* | false | true | | xref:connectors/camel-timer-kafka-source-connector.adoc[Source Docs]
-| *camel-twitter-directmessage-kafka-connector* | true | true | xref:connectors/camel-twitter-directmessage-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-twitter-directmessage-kafka-source-connector.adoc[Source Docs]
-| *camel-twitter-timeline-kafka-connector* | true | true | xref:connectors/camel-twitter-timeline-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-twitter-timeline-kafka-source-connector.adoc[Source Docs]
-| *camel-validator-kafka-connector* | true | false | xref:connectors/camel-validator-kafka-sink-connector.adoc[Sink Docs] |
-| *camel-vertx-kafka-connector* | true | true | xref:connectors/camel-vertx-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-vertx-kafka-source-connector.adoc[Source Docs]
-| *camel-weather-kafka-connector* | true | true | xref:connectors/camel-weather-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-weather-kafka-source-connector.adoc[Source Docs]
-| *camel-webhook-kafka-connector* | false | true | | xref:connectors/camel-webhook-kafka-source-connector.adoc[Source Docs]
-| *camel-websocket-jsr356-kafka-connector* | true | true | xref:connectors/camel-websocket-jsr356-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-websocket-jsr356-kafka-source-connector.adoc[Source Docs]
-| *camel-wordpress-kafka-connector* | true | true | xref:connectors/camel-wordpress-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-wordpress-kafka-source-connector.adoc[Source Docs]
-| *camel-xchange-kafka-connector* | true | false | xref:connectors/camel-xchange-kafka-sink-connector.adoc[Sink Docs] |
-| *camel-xmlsecurity-verify-kafka-connector* | true | false | xref:connectors/camel-xmlsecurity-verify-kafka-sink-connector.adoc[Sink Docs] |
| *camel-pg-replication-slot-kafka-connector* | false | true | | xref:connectors/camel-pg-replication-slot-kafka-source-connector.adoc[Source Docs]
| *camel-pgevent-kafka-connector* | true | true | xref:connectors/camel-pgevent-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-pgevent-kafka-source-connector.adoc[Source Docs]
| *camel-platform-http-kafka-connector* | false | true | | xref:connectors/camel-platform-http-kafka-source-connector.adoc[Source Docs]
@@ -300,8 +269,8 @@ Number of Camel Kafka connectors: 344
| *camel-rabbitmq-kafka-connector* | true | true | xref:connectors/camel-rabbitmq-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-rabbitmq-kafka-source-connector.adoc[Source Docs]
| *camel-reactive-streams-kafka-connector* | true | true | xref:connectors/camel-reactive-streams-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-reactive-streams-kafka-source-connector.adoc[Source Docs]
| *camel-ref-kafka-connector* | true | true | xref:connectors/camel-ref-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-ref-kafka-source-connector.adoc[Source Docs]
-| *camel-rest-kafka-connector* | true | true | xref:connectors/camel-rest-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-rest-kafka-source-connector.adoc[Source Docs]
| *camel-rest-api-kafka-connector* | false | true | | xref:connectors/camel-rest-api-kafka-source-connector.adoc[Source Docs]
+| *camel-rest-kafka-connector* | true | true | xref:connectors/camel-rest-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-rest-kafka-source-connector.adoc[Source Docs]
| *camel-rest-openapi-kafka-connector* | true | false | xref:connectors/camel-rest-openapi-kafka-sink-connector.adoc[Sink Docs] |
| *camel-rest-swagger-kafka-connector* | true | false | xref:connectors/camel-rest-swagger-kafka-sink-connector.adoc[Sink Docs] |
| *camel-robotframework-kafka-connector* | true | true | xref:connectors/camel-robotframework-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-robotframework-kafka-source-connector.adoc[Source Docs]
@@ -319,37 +288,68 @@ Number of Camel Kafka connectors: 344
| *camel-sftp-kafka-connector* | true | true | xref:connectors/camel-sftp-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-sftp-kafka-source-connector.adoc[Source Docs]
| *camel-sip-kafka-connector* | true | true | xref:connectors/camel-sip-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-sip-kafka-source-connector.adoc[Source Docs]
| *camel-sips-kafka-connector* | true | true | xref:connectors/camel-sips-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-sips-kafka-source-connector.adoc[Source Docs]
-| *camel-sjms-kafka-connector* | true | true | xref:connectors/camel-sjms-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-sjms-kafka-source-connector.adoc[Source Docs]
| *camel-sjms-batch-kafka-connector* | false | true | | xref:connectors/camel-sjms-batch-kafka-source-connector.adoc[Source Docs]
+| *camel-sjms-kafka-connector* | true | true | xref:connectors/camel-sjms-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-sjms-kafka-source-connector.adoc[Source Docs]
| *camel-sjms2-kafka-connector* | true | true | xref:connectors/camel-sjms2-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-sjms2-kafka-source-connector.adoc[Source Docs]
| *camel-slack-kafka-connector* | true | true | xref:connectors/camel-slack-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-slack-kafka-source-connector.adoc[Source Docs]
| *camel-smpp-kafka-connector* | true | true | xref:connectors/camel-smpp-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-smpp-kafka-source-connector.adoc[Source Docs]
| *camel-smpps-kafka-connector* | true | true | xref:connectors/camel-smpps-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-smpps-kafka-source-connector.adoc[Source Docs]
+| *camel-smtp-kafka-connector* | true | true | xref:connectors/camel-smtp-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-smtp-kafka-source-connector.adoc[Source Docs]
| *camel-smtps-kafka-connector* | true | true | xref:connectors/camel-smtps-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-smtps-kafka-source-connector.adoc[Source Docs]
+| *camel-snmp-kafka-connector* | true | true | xref:connectors/camel-snmp-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-snmp-kafka-source-connector.adoc[Source Docs]
| *camel-solr-kafka-connector* | true | false | xref:connectors/camel-solr-kafka-sink-connector.adoc[Sink Docs] |
+| *camel-solrcloud-kafka-connector* | true | false | xref:connectors/camel-solrCloud-kafka-sink-connector.adoc[Sink Docs] |
| *camel-solrs-kafka-connector* | true | false | xref:connectors/camel-solrs-kafka-sink-connector.adoc[Sink Docs] |
+| *camel-soroush-kafka-connector* | true | true | xref:connectors/camel-soroush-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-soroush-kafka-source-connector.adoc[Source Docs]
| *camel-spark-kafka-connector* | true | false | xref:connectors/camel-spark-kafka-sink-connector.adoc[Sink Docs] |
+| *camel-spark-rest-kafka-connector* | false | true | | xref:connectors/camel-spark-rest-kafka-source-connector.adoc[Source Docs]
| *camel-splunk-kafka-connector* | true | true | xref:connectors/camel-splunk-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-splunk-kafka-source-connector.adoc[Source Docs]
+| *camel-spring-batch-kafka-connector* | true | false | xref:connectors/camel-spring-batch-kafka-sink-connector.adoc[Sink Docs] |
| *camel-spring-event-kafka-connector* | true | true | xref:connectors/camel-spring-event-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-spring-event-kafka-source-connector.adoc[Source Docs]
+| *camel-spring-integration-kafka-connector* | true | true | xref:connectors/camel-spring-integration-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-spring-integration-kafka-source-connector.adoc[Source Docs]
| *camel-spring-ldap-kafka-connector* | true | false | xref:connectors/camel-spring-ldap-kafka-sink-connector.adoc[Sink Docs] |
+| *camel-spring-redis-kafka-connector* | true | true | xref:connectors/camel-spring-redis-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-spring-redis-kafka-source-connector.adoc[Source Docs]
| *camel-spring-ws-kafka-connector* | true | true | xref:connectors/camel-spring-ws-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-spring-ws-kafka-source-connector.adoc[Source Docs]
+| *camel-sql-kafka-connector* | true | true | xref:connectors/camel-sql-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-sql-kafka-source-connector.adoc[Source Docs]
| *camel-sql-stored-kafka-connector* | true | false | xref:connectors/camel-sql-stored-kafka-sink-connector.adoc[Sink Docs] |
+| *camel-ssh-kafka-connector* | true | true | xref:connectors/camel-ssh-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-ssh-kafka-source-connector.adoc[Source Docs]
| *camel-stax-kafka-connector* | true | false | xref:connectors/camel-stax-kafka-sink-connector.adoc[Sink Docs] |
+| *camel-stomp-kafka-connector* | true | true | xref:connectors/camel-stomp-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-stomp-kafka-source-connector.adoc[Source Docs]
| *camel-stream-kafka-connector* | true | true | xref:connectors/camel-stream-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-stream-kafka-source-connector.adoc[Source Docs]
+| *camel-string-template-kafka-connector* | true | false | xref:connectors/camel-string-template-kafka-sink-connector.adoc[Sink Docs] |
| *camel-stub-kafka-connector* | true | true | xref:connectors/camel-stub-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-stub-kafka-source-connector.adoc[Source Docs]
| *camel-telegram-kafka-connector* | true | true | xref:connectors/camel-telegram-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-telegram-kafka-source-connector.adoc[Source Docs]
+| *camel-thrift-kafka-connector* | true | true | xref:connectors/camel-thrift-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-thrift-kafka-source-connector.adoc[Source Docs]
| *camel-tika-kafka-connector* | true | false | xref:connectors/camel-tika-kafka-sink-connector.adoc[Sink Docs] |
+| *camel-timer-kafka-connector* | false | true | | xref:connectors/camel-timer-kafka-source-connector.adoc[Source Docs]
| *camel-twilio-kafka-connector* | true | true | xref:connectors/camel-twilio-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-twilio-kafka-source-connector.adoc[Source Docs]
+| *camel-twitter-directmessage-kafka-connector* | true | true | xref:connectors/camel-twitter-directmessage-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-twitter-directmessage-kafka-source-connector.adoc[Source Docs]
| *camel-twitter-search-kafka-connector* | true | true | xref:connectors/camel-twitter-search-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-twitter-search-kafka-source-connector.adoc[Source Docs]
+| *camel-twitter-timeline-kafka-connector* | true | true | xref:connectors/camel-twitter-timeline-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-twitter-timeline-kafka-source-connector.adoc[Source Docs]
| *camel-undertow-kafka-connector* | true | true | xref:connectors/camel-undertow-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-undertow-kafka-source-connector.adoc[Source Docs]
+| *camel-validator-kafka-connector* | true | false | xref:connectors/camel-validator-kafka-sink-connector.adoc[Sink Docs] |
| *camel-velocity-kafka-connector* | true | false | xref:connectors/camel-velocity-kafka-sink-connector.adoc[Sink Docs] |
+| *camel-vertx-kafka-connector* | true | true | xref:connectors/camel-vertx-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-vertx-kafka-source-connector.adoc[Source Docs]
| *camel-vm-kafka-connector* | true | true | xref:connectors/camel-vm-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-vm-kafka-source-connector.adoc[Source Docs]
+| *camel-weather-kafka-connector* | true | true | xref:connectors/camel-weather-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-weather-kafka-source-connector.adoc[Source Docs]
| *camel-web3j-kafka-connector* | true | true | xref:connectors/camel-web3j-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-web3j-kafka-source-connector.adoc[Source Docs]
+| *camel-webhook-kafka-connector* | false | true | | xref:connectors/camel-webhook-kafka-source-connector.adoc[Source Docs]
+| *camel-websocket-jsr356-kafka-connector* | true | true | xref:connectors/camel-websocket-jsr356-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-websocket-jsr356-kafka-source-connector.adoc[Source Docs]
| *camel-websocket-kafka-connector* | true | true | xref:connectors/camel-websocket-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-websocket-kafka-source-connector.adoc[Source Docs]
| *camel-weka-kafka-connector* | true | false | xref:connectors/camel-weka-kafka-sink-connector.adoc[Sink Docs] |
+| *camel-wordpress-kafka-connector* | true | true | xref:connectors/camel-wordpress-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-wordpress-kafka-source-connector.adoc[Source Docs]
| *camel-workday-kafka-connector* | true | false | xref:connectors/camel-workday-kafka-sink-connector.adoc[Sink Docs] |
+| *camel-xchange-kafka-connector* | true | false | xref:connectors/camel-xchange-kafka-sink-connector.adoc[Sink Docs] |
| *camel-xj-kafka-connector* | true | false | xref:connectors/camel-xj-kafka-sink-connector.adoc[Sink Docs] |
| *camel-xmlsecurity-sign-kafka-connector* | true | false | xref:connectors/camel-xmlsecurity-sign-kafka-sink-connector.adoc[Sink Docs] |
+| *camel-xmlsecurity-verify-kafka-connector* | true | false | xref:connectors/camel-xmlsecurity-verify-kafka-sink-connector.adoc[Sink Docs] |
| *camel-xmpp-kafka-connector* | true | true | xref:connectors/camel-xmpp-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-xmpp-kafka-source-connector.adoc[Source Docs]
+| *camel-xquery-kafka-connector* | true | true | xref:connectors/camel-xquery-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-xquery-kafka-source-connector.adoc[Source Docs]
+| *camel-xslt-kafka-connector* | true | false | xref:connectors/camel-xslt-kafka-sink-connector.adoc[Sink Docs] |
+| *camel-xslt-saxon-kafka-connector* | true | false | xref:connectors/camel-xslt-saxon-kafka-sink-connector.adoc[Sink Docs] |
+| *camel-yammer-kafka-connector* | true | true | xref:connectors/camel-yammer-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-yammer-kafka-source-connector.adoc[Source Docs]
+| *camel-zendesk-kafka-connector* | true | true | xref:connectors/camel-zendesk-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-zendesk-kafka-source-connector.adoc[Source Docs]
+| *camel-zookeeper-kafka-connector* | true | true | xref:connectors/camel-zookeeper-kafka-sink-connector.adoc[Sink Docs] | xref:connectors/camel-zookeeper-kafka-source-connector.adoc[Source Docs]
+| *camel-zookeeper-master-kafka-connector* | false | true | | xref:connectors/camel-zookeeper-master-kafka-source-connector.adoc[Source Docs]
|===
// kafka-connectors list: END
[camel-kafka-connector] 02/03: Ordered the component list by name
in order to change only if components are added or removed.
Posted by va...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
valdar pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit a54fa694def3b88fce03f7ef244379990090b32d
Author: Andrea Tarocchi <an...@gmail.com>
AuthorDate: Fri May 8 23:31:40 2020 +0200
Ordered the component list by name in order to change only if components are added or removed.
---
.../maven/docs/UpdateDocComponentsListMojo.java | 22 ++++++++++++----------
.../docs/dto/CamelKafkaConnectorTableModel.java | 8 ++++----
2 files changed, 16 insertions(+), 14 deletions(-)
diff --git a/tooling/camel-kafka-connector-docs-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/docs/UpdateDocComponentsListMojo.java b/tooling/camel-kafka-connector-docs-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/docs/UpdateDocComponentsListMojo.java
index 183cf87..b821027 100644
--- a/tooling/camel-kafka-connector-docs-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/docs/UpdateDocComponentsListMojo.java
+++ b/tooling/camel-kafka-connector-docs-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/docs/UpdateDocComponentsListMojo.java
@@ -21,7 +21,6 @@ import java.io.FileInputStream;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
-import java.util.List;
import org.apache.camel.kafkaconnector.maven.docs.dto.CamelKafkaConnectorTableModel;
import org.apache.camel.kafkaconnector.maven.docs.dto.CamelKafkaConnectorTableOptionModel;
@@ -49,6 +48,9 @@ import static org.apache.camel.tooling.util.PackageHelper.writeText;
*/
@Mojo(name = "update-doc-connectors-list", threadSafe = true)
public class UpdateDocComponentsListMojo extends AbstractMojo {
+ private static final String SINK_CONNECTOR_LINK_SUFFIX_ADOC = "kafka-sink-connector.adoc[Sink Docs]";
+ private static final String SOURCE_CONNECTOR_LINK_SUFFIX_ADOC = "kafka-source-connector.adoc[Source Docs]";
+ private static final String XREF_CONNECTOR_LINK_PREFIX = "xref:connectors/";
/**
* The maven project.
@@ -73,10 +75,6 @@ public class UpdateDocComponentsListMojo extends AbstractMojo {
*/
@Component
private MavenProjectHelper projectHelper;
-
- private final String SINK_CONNECTOR_LINK_SUFFIX_ADOC = "kafka-sink-connector.adoc[Sink Docs]";
- private final String SOURCE_CONNECTOR_LINK_SUFFIX_ADOC = "kafka-source-connector.adoc[Source Docs]";
- private final String XREF_CONNECTOR_LINK_PREFIX = "xref:connectors/";
/**
* Execute goal.
@@ -92,7 +90,7 @@ public class UpdateDocComponentsListMojo extends AbstractMojo {
protected void executeComponentsReadme() throws MojoExecutionException, MojoFailureException {
CamelKafkaConnectorTableModel tableModel = new CamelKafkaConnectorTableModel();
- List<CamelKafkaConnectorTableOptionModel> options = new ArrayList<CamelKafkaConnectorTableOptionModel>();
+ ArrayList<CamelKafkaConnectorTableOptionModel> options = new ArrayList<CamelKafkaConnectorTableOptionModel>();
if (connectorsDir != null && connectorsDir.isDirectory()) {
File[] files = connectorsDir.listFiles();
@@ -110,8 +108,7 @@ public class UpdateDocComponentsListMojo extends AbstractMojo {
String connectorFinal = StringUtils.removeEnd(file.getName(), "kafka-connector");
if (connectorFinal.equalsIgnoreCase("camel-coap-tcp-")) {
singleConnector.setDocsSink("xref:connectors/camel-coap+tcp-kafka-sink-connector.adoc[Sink Docs]");
- }
- else if (connectorFinal.equalsIgnoreCase("camel-coaps-tcp-")) {
+ } else if (connectorFinal.equalsIgnoreCase("camel-coaps-tcp-")) {
singleConnector.setDocsSink("xref:connectors/camel-coaps+tcp-kafka-sink-connector.adoc[Sink Docs]");
} else if (connectorFinal.equalsIgnoreCase("camel-solrcloud-")) {
singleConnector.setDocsSink("xref:connectors/camel-solrCloud-kafka-sink-connector.adoc[Sink Docs]");
@@ -124,8 +121,7 @@ public class UpdateDocComponentsListMojo extends AbstractMojo {
String connectorFinal = StringUtils.removeEnd(file.getName(), "kafka-connector");
if (connectorFinal.equalsIgnoreCase("camel-coap-tcp-")) {
singleConnector.setDocsSource("xref:connectors/camel-coap+tcp-kafka-source-connector.adoc[Source Docs]");
- }
- else if (connectorFinal.equalsIgnoreCase("camel-coaps-tcp-")) {
+ } else if (connectorFinal.equalsIgnoreCase("camel-coaps-tcp-")) {
singleConnector.setDocsSource("xref:connectors/camel-coaps+tcp-kafka-source-connector.adoc[Source Docs]");
} else if (connectorFinal.equalsIgnoreCase("camel-solrcloud-")) {
singleConnector.setDocsSource("xref:connectors/camel-solrCloud-kafka-source-connector.adoc[Source Docs]");
@@ -137,6 +133,12 @@ public class UpdateDocComponentsListMojo extends AbstractMojo {
}
}
}
+ options.sort((model1, model2) -> {
+ String name1 = model1.getName();
+ String name2 = model2.getName();
+ int res = String.CASE_INSENSITIVE_ORDER.compare(name1, name2);
+ return (res != 0) ? res : name1.compareTo(name2);
+ });
tableModel.setOptions(options);
}
}
diff --git a/tooling/camel-kafka-connector-docs-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/docs/dto/CamelKafkaConnectorTableModel.java b/tooling/camel-kafka-connector-docs-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/docs/dto/CamelKafkaConnectorTableModel.java
index 71d8475..840dfc7 100644
--- a/tooling/camel-kafka-connector-docs-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/docs/dto/CamelKafkaConnectorTableModel.java
+++ b/tooling/camel-kafka-connector-docs-maven-plugin/src/main/java/org/apache/camel/kafkaconnector/maven/docs/dto/CamelKafkaConnectorTableModel.java
@@ -16,17 +16,17 @@
*/
package org.apache.camel.kafkaconnector.maven.docs.dto;
-import java.util.List;
+import java.util.ArrayList;
public class CamelKafkaConnectorTableModel {
- private List<CamelKafkaConnectorTableOptionModel> options;
+ private ArrayList<CamelKafkaConnectorTableOptionModel> options;
- public List<CamelKafkaConnectorTableOptionModel> getOptions() {
+ public ArrayList<CamelKafkaConnectorTableOptionModel> getOptions() {
return options;
}
- public void setOptions(List<CamelKafkaConnectorTableOptionModel> options) {
+ public void setOptions(ArrayList<CamelKafkaConnectorTableOptionModel> options) {
this.options = options;
}