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:22 UTC
[camel-kafka-connector] 03/03: Move
ConnectRecordValueToMapTransformer of Elastisearch IT test in the connector
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();