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/20 18:36:19 UTC
[camel-kafka-connector] branch master updated (1a225e7 -> 79d3a80)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git.
from 1a225e7 Regen catalog
new 7fb55bd Move ConnectRecordValueToMapTransformer of Elastisearch IT test in the connector
new 5e2bc08 Regen
new 79d3a80 Move ConnectRecordValueToMapTransformer of Elastisearch IT test in the connector
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:
.../resources/connectors/camel-elasticsearch-rest-sink.json | 5 ++++-
.../src/generated/resources/camel-elasticsearch-rest-sink.json | 5 ++++-
.../main/docs/camel-elasticsearch-rest-kafka-sink-connector.adoc | 9 ++++++++-
.../transformers/ConnectRecordValueToMapTransforms.java | 5 ++---
.../camel-elasticsearch-rest-kafka-sink-connector.adoc | 9 ++++++++-
.../elasticsearch/sink/CamelSinkElasticSearchITCase.java | 8 ++++----
6 files changed, 30 insertions(+), 11 deletions(-)
rename tests/itests-elasticsearch/src/test/java/org/apache/camel/kafkaconnector/elasticsearch/sink/transform/ConnectRecordValueToMapTransformer.java => connectors/camel-elasticsearch-rest-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/elasticsearchrest/transformers/ConnectRecordValueToMapTransforms.java (92%)
[camel-kafka-connector] 01/03: Move
ConnectRecordValueToMapTransformer of Elastisearch IT test in the connector
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 7fb55bd1bd717bf171c5b0c08716ccc02612b55a
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Oct 20 18:16:28 2020 +0200
Move ConnectRecordValueToMapTransformer of Elastisearch IT test in the connector
---
.../transformers/ConnectRecordValueToMapTransforms.java | 5 ++---
.../elasticsearch/sink/CamelSinkElasticSearchITCase.java | 4 ++--
2 files changed, 4 insertions(+), 5 deletions(-)
diff --git a/tests/itests-elasticsearch/src/test/java/org/apache/camel/kafkaconnector/elasticsearch/sink/transform/ConnectRecordValueToMapTransformer.java b/connectors/camel-elasticsearch-rest-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/elasticsearchrest/transformers/ConnectRecordValueToMapTransforms.java
similarity index 92%
rename from tests/itests-elasticsearch/src/test/java/org/apache/camel/kafkaconnector/elasticsearch/sink/transform/ConnectRecordValueToMapTransformer.java
rename to connectors/camel-elasticsearch-rest-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/elasticsearchrest/transformers/ConnectRecordValueToMapTransforms.java
index 14ee8e8..3fd1252 100644
--- a/tests/itests-elasticsearch/src/test/java/org/apache/camel/kafkaconnector/elasticsearch/sink/transform/ConnectRecordValueToMapTransformer.java
+++ b/connectors/camel-elasticsearch-rest-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/elasticsearchrest/transformers/ConnectRecordValueToMapTransforms.java
@@ -14,8 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
-package org.apache.camel.kafkaconnector.elasticsearch.sink.transform;
+package org.apache.camel.kafkaconnector.elasticsearchrest.transformers;
import java.util.HashMap;
import java.util.Map;
@@ -27,7 +26,7 @@ import org.apache.kafka.connect.connector.ConnectRecord;
import org.apache.kafka.connect.transforms.Transformation;
import org.apache.kafka.connect.transforms.util.SimpleConfig;
-public class ConnectRecordValueToMapTransformer<R extends ConnectRecord<R>> implements Transformation<R> {
+public class ConnectRecordValueToMapTransforms<R extends ConnectRecord<R>> implements Transformation<R> {
public static final String FIELD_KEY_CONFIG = "key";
public static final ConfigDef CONFIG_DEF = new ConfigDef()
diff --git a/tests/itests-elasticsearch/src/test/java/org/apache/camel/kafkaconnector/elasticsearch/sink/CamelSinkElasticSearchITCase.java b/tests/itests-elasticsearch/src/test/java/org/apache/camel/kafkaconnector/elasticsearch/sink/CamelSinkElasticSearchITCase.java
index 80834dd..975c3a6 100644
--- a/tests/itests-elasticsearch/src/test/java/org/apache/camel/kafkaconnector/elasticsearch/sink/CamelSinkElasticSearchITCase.java
+++ b/tests/itests-elasticsearch/src/test/java/org/apache/camel/kafkaconnector/elasticsearch/sink/CamelSinkElasticSearchITCase.java
@@ -146,8 +146,8 @@ public class CamelSinkElasticSearchITCase extends AbstractKafkaTest {
.withClusterName(ElasticSearchCommon.DEFAULT_ELASTICSEARCH_CLUSTER)
.withHostAddress(elasticSearch.getHttpHostAddress())
.withIndexName(ElasticSearchCommon.DEFAULT_ELASTICSEARCH_INDEX)
- .withTransformsConfig("ElasticSearchTransformer")
- .withEntry("type", "org.apache.camel.kafkaconnector.elasticsearch.sink.transform.ConnectRecordValueToMapTransformer")
+ .withTransformsConfig("ElasticSearchTransforms")
+ .withEntry("type", "org.apache.camel.kafkaconnector.elasticsearchrest.transformers.ConnectRecordValueToMapTransforms")
.withEntry("key", transformKey)
.end();
[camel-kafka-connector] 03/03: Move
ConnectRecordValueToMapTransformer of Elastisearch IT test in the connector
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 79d3a8024b421bf377cff31d6ba12158ec5b6ad2
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Oct 20 19:17:46 2020 +0200
Move ConnectRecordValueToMapTransformer of Elastisearch IT test in the connector
---
.../elasticsearch/sink/CamelSinkElasticSearchITCase.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/tests/itests-elasticsearch/src/test/java/org/apache/camel/kafkaconnector/elasticsearch/sink/CamelSinkElasticSearchITCase.java b/tests/itests-elasticsearch/src/test/java/org/apache/camel/kafkaconnector/elasticsearch/sink/CamelSinkElasticSearchITCase.java
index 975c3a6..d442692 100644
--- a/tests/itests-elasticsearch/src/test/java/org/apache/camel/kafkaconnector/elasticsearch/sink/CamelSinkElasticSearchITCase.java
+++ b/tests/itests-elasticsearch/src/test/java/org/apache/camel/kafkaconnector/elasticsearch/sink/CamelSinkElasticSearchITCase.java
@@ -174,8 +174,8 @@ public class CamelSinkElasticSearchITCase extends AbstractKafkaTest {
.append("operation", "Index")
.append("indexName", ElasticSearchCommon.DEFAULT_ELASTICSEARCH_INDEX)
.buildUrl()
- .withTransformsConfig("ElasticSearchTransformer")
- .withEntry("type", "org.apache.camel.kafkaconnector.elasticsearch.sink.transform.ConnectRecordValueToMapTransformer")
+ .withTransformsConfig("ElasticSearchTransforms")
+ .withEntry("type", "org.apache.camel.kafkaconnector.elasticsearchrest.transformers.ConnectRecordValueToMapTransforms")
.withEntry("key", transformKey)
.end();
[camel-kafka-connector] 02/03: Regen
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 5e2bc08ef3b3c3b4b1ced64805acb1285de58386
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Oct 20 18:52:36 2020 +0200
Regen
---
.../resources/connectors/camel-elasticsearch-rest-sink.json | 5 ++++-
.../src/generated/resources/camel-elasticsearch-rest-sink.json | 5 ++++-
.../main/docs/camel-elasticsearch-rest-kafka-sink-connector.adoc | 9 ++++++++-
.../camel-elasticsearch-rest-kafka-sink-connector.adoc | 9 ++++++++-
4 files changed, 24 insertions(+), 4 deletions(-)
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-elasticsearch-rest-sink.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-elasticsearch-rest-sink.json
index 2823d99..91f33fd 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-elasticsearch-rest-sink.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-elasticsearch-rest-sink.json
@@ -196,5 +196,8 @@
"description": "Basic authenticate user",
"priority": "MEDIUM"
}
- }
+ },
+ "transforms": [
+ "org.apache.camel.kafkaconnector.elasticsearchrest.transformers.ConnectRecordValueToMapTransforms"
+ ]
}
\ No newline at end of file
diff --git a/connectors/camel-elasticsearch-rest-kafka-connector/src/generated/resources/camel-elasticsearch-rest-sink.json b/connectors/camel-elasticsearch-rest-kafka-connector/src/generated/resources/camel-elasticsearch-rest-sink.json
index 2823d99..91f33fd 100644
--- a/connectors/camel-elasticsearch-rest-kafka-connector/src/generated/resources/camel-elasticsearch-rest-sink.json
+++ b/connectors/camel-elasticsearch-rest-kafka-connector/src/generated/resources/camel-elasticsearch-rest-sink.json
@@ -196,5 +196,8 @@
"description": "Basic authenticate user",
"priority": "MEDIUM"
}
- }
+ },
+ "transforms": [
+ "org.apache.camel.kafkaconnector.elasticsearchrest.transformers.ConnectRecordValueToMapTransforms"
+ ]
}
\ No newline at end of file
diff --git a/connectors/camel-elasticsearch-rest-kafka-connector/src/main/docs/camel-elasticsearch-rest-kafka-sink-connector.adoc b/connectors/camel-elasticsearch-rest-kafka-connector/src/main/docs/camel-elasticsearch-rest-kafka-sink-connector.adoc
index e7ccdd7..9d52301 100644
--- a/connectors/camel-elasticsearch-rest-kafka-connector/src/main/docs/camel-elasticsearch-rest-kafka-sink-connector.adoc
+++ b/connectors/camel-elasticsearch-rest-kafka-connector/src/main/docs/camel-elasticsearch-rest-kafka-sink-connector.adoc
@@ -72,10 +72,17 @@ The camel-elasticsearch-rest sink connector has no converters out of the box.
-The camel-elasticsearch-rest sink connector has no transforms out of the box.
+The camel-elasticsearch-rest sink connector supports 0 transforms out of the box, which are listed below.
+[source,java]
+----
+
+org.apache.camel.kafkaconnector.elasticsearchrest.transformers.ConnectRecordValueToMapTransforms
+
+----
+
The camel-elasticsearch-rest sink connector has no aggregation strategies out of the box.
diff --git a/docs/modules/ROOT/pages/connectors/camel-elasticsearch-rest-kafka-sink-connector.adoc b/docs/modules/ROOT/pages/connectors/camel-elasticsearch-rest-kafka-sink-connector.adoc
index e7ccdd7..9d52301 100644
--- a/docs/modules/ROOT/pages/connectors/camel-elasticsearch-rest-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-elasticsearch-rest-kafka-sink-connector.adoc
@@ -72,10 +72,17 @@ The camel-elasticsearch-rest sink connector has no converters out of the box.
-The camel-elasticsearch-rest sink connector has no transforms out of the box.
+The camel-elasticsearch-rest sink connector supports 0 transforms out of the box, which are listed below.
+[source,java]
+----
+
+org.apache.camel.kafkaconnector.elasticsearchrest.transformers.ConnectRecordValueToMapTransforms
+
+----
+
The camel-elasticsearch-rest sink connector has no aggregation strategies out of the box.