orpiske edited a comment on issue #138: URL: https://github.com/apache/camel-kafka-connector/pull/138#issuecomment-617819293
~~BTW: to remove the ElasticSearch error, we need to find a way to stop requiring the [ConnectRecordValueToMapTransformer](https://github.com/apache/camel-kafka-connector/blob/master/tests/src/test/java/org/apache/camel/kafkaconnector/sink/elasticsearch/transforms/ConnectRecordValueToMapTransformer.java) class. It does the transformation from the key/pair data format used in ElasticSearch to the record format used by the Kafka message. If we have a way to do this conversion automatically, then we can remove this class and [the dependency](https://github.com/apache/camel-kafka-connector/blob/master/tests/pom.xml#L49) on the `camel-elasticsearch-rest-kafka-connector`. This should do the trick of removing the last DelegationClassLoader error on the logs.~~ Ahhh, no. @valdar gave me an idea that solves the problem without any of this. Just changing the elasticsearch provided dependency to the core one did the trick. Huge thanks for his idea! ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
