[GitHub] [camel-kafka-connector] R-Lam commented on issue #342: Camel-Elasticsearch Connector not working on OpenShift

[GitBox]

R-Lam commented on issue #342:
URL: 
https://github.com/apache/camel-kafka-connector/issues/342#issuecomment-665794972


   Here's the list of plugins on `/opt/kafka/plugins`:
   
![image](https://user-images.githubusercontent.com/25209945/88831272-5af73b00-d18c-11ea-929f-78eb4df4def9.png)
   
   And here's the result of `connector-plugins`:
   ```
   [
     {
       "class": "org.apache.camel.kafkaconnector.CamelSinkConnector",
       "type": "sink",
       "version": "0.3.0"
     },
     {
       "class": "org.apache.camel.kafkaconnector.CamelSourceConnector",
       "type": "source",
       "version": "0.3.0"
     },
     {
       "class": "org.apache.kafka.connect.file.FileStreamSinkConnector",
       "type": "sink",
       "version": "2.5.0.redhat-00003"
     },
     {
       "class": "org.apache.kafka.connect.file.FileStreamSourceConnector",
       "type": "source",
       "version": "2.5.0.redhat-00003"
     },
     {
       "class": "org.apache.kafka.connect.mirror.MirrorCheckpointConnector",
       "type": "source",
       "version": "1"
     },
     {
       "class": "org.apache.kafka.connect.mirror.MirrorHeartbeatConnector",
       "type": "source",
       "version": "1"
     },
     {
       "class": "org.apache.kafka.connect.mirror.MirrorSourceConnector",
       "type": "source",
       "version": "1"
     }
   ]
   ```
   
   > The configuration class is wrong
   > you need to set this class here: 
https://github.com/apache/camel-kafka-connector/blob/master/connectors/camel-elasticsearch-rest-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/elasticsearchrest/CamelElasticsearchrestSinkConnector.java
   > 
   > Setting the generic class won't work.
   
   Yes, I already tried with the class mentioned in the example folder, but is 
still missing:
   ```
   ERROR Uncaught exception in REST call to /connectors/camel-connector/config 
(org.apache.kafka.connect.runtime.rest.errors.ConnectExceptionMapper) 
[qtp1126112943-92]
   org.apache.kafka.connect.errors.ConnectException: Failed to find any class 
that implements Connector and which name matches 
org.apache.camel.kafkaconnector.elasticsearchrest.CamelElasticsearchrestSinkConnector
   ```


----------------------------------------------------------------
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