Hi,

The error seems related to Kafka bundle.

Can you check if Kafka bundle version is 2.6.0_2 ?

Regards
JB

> Le 17 mai 2021 à 18:42, Nicola Cisternino <ncistern...@gmail.com> a écrit :
> 
> Hi all
> I'm using Apache Karaf 4.3.1 to route netty socket on Kafka:
> 
> cat > deploy/example.xml <<END
> <blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0";>
>    <camelContext xmlns="http://camel.apache.org/schema/blueprint"; id="kafka">
>        <route id="kafka">
>            <from 
> uri="mina:tcp://0.0.0.0:8888?decoderMaxLineLength=8192&amp;textline=true&amp;sync=false"/>
>            <to uri="kafka:users?brokers=192.168.1.231:9092"/>
>        </route>
>    </camelContext>
> </blueprint>
> END
> 
> Using Camel 3.5.0 all works fine (from gogo shell):
> feature:install http webconsole         
> feature:repo-add camel 3.5.0
> feature:install camel camel-netty camel-kafka
> 
> Using last Camel 3.7.3 version (plus 3 Jackson Bundles) with same features:
> feature:install http webconsole
> feature:repo-add camel 3.7.3
> feature:install camel camel-netty camel-kafka
> 
> .. the following error occurs:
> 
> 16:33:39.663 INFO [Blueprint Event Dispatcher: 1] Kafka version: 2.6.0
> 16:33:39.664 INFO [Blueprint Event Dispatcher: 1] Kafka commitId: 
> 62abe01bee039651
> 16:33:39.664 INFO [Blueprint Event Dispatcher: 1] Kafka startTimeMs: 
> 1621269219663
> 16:33:39.665 ERROR [kafka-producer-network-thread | producer-2] Uncaught 
> exception in thread 'kafka-producer-network-thread | producer-2':
> java.lang.NoClassDefFoundError: Could not initialize class 
> org.apache.kafka.common.requests.ApiVersionsRequest$Builder
>       at 
> org.apache.kafka.clients.NetworkClient.handleConnections(NetworkClient.java:910)
>  ~[!/:?]
>       at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:555) 
> ~[!/:?]
>       at 
> org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:325) 
> ~[!/:?]
>       at 
> org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:240) 
> ~[!/:?]
>       at java.lang.Thread.run(Unknown Source) [?:?]
> 
> Any idea ?
> 
> 
> 
> 

Reply via email to