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

[GitBox]

R-Lam opened a new issue #342:
URL: https://github.com/apache/camel-kafka-connector/issues/342


   I'm trying to use the camel elasticsearch connector with my Kafka cluster on 
OpenShift but on my Connect instance I'm getting this warnings for the 
'exchange' class not found and then failed to start the CamelSinkConnector 
class.
   
   Here's the log:
   
   ```
   2020-07-29 15:57:09,912 WARN /connectors/camel-connector/config 
(org.eclipse.jetty.server.HttpChannel) [qtp1064315206-118]
   javax.servlet.ServletException: 
org.glassfish.jersey.server.ContainerException: java.lang.NoClassDefFoundError: 
org/apache/camel/Exchange
        at 
org.glassfish.jersey.servlet.WebComponent.serviceImpl(WebComponent.java:408)
        at 
org.glassfish.jersey.servlet.WebComponent.service(WebComponent.java:346)
        ...
   Caused by: org.glassfish.jersey.server.ContainerException: 
java.lang.NoClassDefFoundError: org/apache/camel/Exchange
   ```
   As I mention, after some time has passed, this comes out:
   ```
   WARN unhandled due to prior sendError 
(org.eclipse.jetty.server.HttpChannelState) [qtp1064315206-119]
   javax.servlet.ServletException: 
org.glassfish.jersey.server.ContainerException: java.lang.NoClassDefFoundError: 
Could not initialize class 
org.apache.camel.kafkaconnector.CamelSinkConnectorConfig
   ```
   
   I'm working with this dockerfile:
   ```
   FROM registry.redhat.io/amq7/amq-streams-kafka-25-rhel7:1.5.0
   USER root:root
   COPY camel-elasticsearch-rest-kafka-connector/ /opt/kafka/plugins/
   USER 1001
   ```
   
   And this is the config of the Connector:
   ```
   apiVersion: kafka.strimzi.io/v1alpha1
   kind: KafkaConnector
   metadata:
     name: camel-connector
     labels:
       strimzi.io/cluster: camel-connect
     namespace: demo-amq-streams
   spec:
     class: org.apache.camel.kafkaconnector.CamelSinkConnector
     config:
       key.converter: org.apache.kafka.connect.storage.StringConverter
       value.converter: org.apache.kafka.connect.storage.StringConverter
       camel.sink.url: 
elasticsearch-rest://elasticsearch?hostAddresses=elasticsearch:9200&operation=Index&indexName=customers
       topics: smt.inventory.customers
     tasksMax: 1
   ```


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