Details
-
Bug
-
Status: Open
-
Major
-
Resolution: Unresolved
-
7.0.1, 7.1.0
-
None
-
None
-
JRE 8 update 172. Windows 10.
Kafka in docker (wurstmeister/kafka) and kafka on Win Server using quickstart scripts. Both give same issue.
feature:install camel-kafka
route info for the Camel 2.16 URL notation:
<from id="Kafka" uri="kafka:localhost:9092?topic=test&groupId=testing&zookeeperHost=localhost&zookeeperPort=2181"/> <to id="fileout" uri="file://c:/esb/kafkaconsumer"/>
Reproduced on 7.0.1 and 7.1.0 (20190113.134104-3)
Bug does not appear in Talend ESB which uses Camel 2.17 with alternate Kafka implementation
JRE 8 update 172. Windows 10. Kafka in docker (wurstmeister/kafka) and kafka on Win Server using quickstart scripts. Both give same issue. feature:install camel-kafka route info for the Camel 2.16 URL notation: <from id= "Kafka" uri= "kafka:localhost:9092?topic=test&groupId=testing&zookeeperHost=localhost&zookeeperPort=2181" /> <to id= "fileout" uri= "file: //c:/esb/kafkaconsumer" /> Reproduced on 7.0.1 and 7.1.0 (20190113.134104-3) Bug does not appear in Talend ESB which uses Camel 2.17 with alternate Kafka implementation
Description
I'm trying to use a camel-route that would take a message from a Apache Kafka instance.
Instead of an active route I get an exception that appears to come from the zookeeper system bundle.
java.lang.NoClassDefFoundError: org/ietf/jgss/GSSException at org.apache.zookeeper.ClientCnxn$SendThread.startConnect(ClientCnxn.java:945)[99:org.apache.hadoop.zookeeper:3.4.6] at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1003)[99:org.apache.hadoop.zookeeper:3.4.6] Caused by: java.lang.ClassNotFoundException: org.ietf.jgss.GSSException not found by org.apache.hadoop.zookeeper [99]
That error is consistent with Zookeeper bug ZOOKEEPER-1942 (and possibly 2056) as a malformed OSGi manifest. Jira tickets mention a patch or later version with fix.
I've tried using OSGi wrap: and fragments for the org.ietf.jgss package without success, against the zookeeper provided bundle and the zkclient camel dependency.
Camel route declared as active in bundle list, with secondary error message preceding activation in servicemix log:
BlueprintCamelContext | 40 - org.apache.camel.camel-blueprint - 2.16.5 | Error occurred during starting Camel: CamelContext(context1) due Unable to connect to zookeeper server within timeout: 6000 org.I0Itec.zkclient.exception.ZkTimeoutException: Unable to connect to zookeeper server within timeout: 6000