Errata corrige (route): 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="netty:tcp://0.0.0.0:9999"/> <to uri="kafka:users?brokers=192.168.1.231:9092"/> </route> </camelContext> </blueprint> END
On 2021/05/17 16:42:10, Nicola Cisternino <ncistern...@gmail.com> wrote: > 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&textline=true&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 ? > > > > >
