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