骆驼elasticsearch5组件不起作用

我的项目消耗activemq消息并存储到elasticsearch 2.4数据库与技术karaf 4.0.8，Apache骆驼（2.18.1），驼峰elasticsearch组件。我正在尝试升级到elasticsearch 5数据库，并要求在客户端进行更改。我发现新的骆驼组件camel-elasticsearch5与apache-camel 2.19.0一样。我升级骆驼。之后，它看起来没有按预期工作。 1. camel命令如camel：context-list不起作用。 2.路由不起作用，如messaged不从activemq消耗。骆驼elasticsearch5组件不起作用

此外，日志中还有警告。

2017-07-18 06:57:27,144 | INFO | nt Dispatcher: 1 | ElasticsearchProducer   | 21 - org.apache.camel.camel-elasticsearch5 - 2.19.0 | Connecting to the ElasticSearch cluster: elasticsearch 
 
2017-07-18 06:57:27,145 | WARN | -SNAPSHOT/deploy | BlueprintEventDispatcher   | 83 - org.apache.aries.blueprint.core - 1.7.1 | Listener caused an exception, will be ignored 
 
java.util.concurrent.ExecutionException: java.lang.NoClassDefFoundError: Could not initialize class org.elasticsearch.transport.client.PreBuiltTransportClient 
 
     at java.util.concurrent.FutureTask.report(FutureTask.java:122)[:1.8.0_121] 
 
     at java.util.concurrent.FutureTask.get(FutureTask.java:192)[:1.8.0_121] 
 
     at java.util.concurrent.AbstractExecutorService.doInvokeAny(AbstractExecutorService.java:193)[:1.8.0_121] 
 
     at java.util.concurrent.AbstractExecutorService.invokeAny(AbstractExecutorService.java:225)[:1.8.0_121] 
 
     at org.apache.aries.blueprint.utils.threading.ScheduledExecutorServiceWrapper$4.call(ScheduledExecutorServiceWrapper.java:184)[83:org.apache.aries.blueprint.core:1.7.1] 
 
     at org.apache.aries.blueprint.utils.threading.ScheduledExecutorServiceWrapper$15.call(ScheduledExecutorServiceWrapper.java:452)[83:org.apache.aries.blueprint.core:1.7.1] 
 
     at org.apache.aries.blueprint.utils.threading.RWLock.runReadOperation(RWLock.java:35)[83:org.apache.aries.blueprint.core:1.7.1] 
 
     at org.apache.aries.blueprint.utils.threading.ScheduledExecutorServiceWrapper.runUnlessShutdown(ScheduledExecutorServiceWrapper.java:447)[83:org.apache.aries.blueprint.core:1.7.1] 
 
     at org.apache.aries.blueprint.utils.threading.ScheduledExecutorServiceWrapper.invokeAny(ScheduledExecutorServiceWrapper.java:178)[83:org.apache.aries.blueprint.core:1.7.1] 
 
     at org.apache.aries.blueprint.container.BlueprintEventDispatcher.callListener(BlueprintEventDispatcher.java:199)[83:org.apache.aries.blueprint.core:1.7.1] 
 
     at org.apache.aries.blueprint.container.BlueprintEventDispatcher.callListeners(BlueprintEventDispatcher.java:189)[83:org.apache.aries.blueprint.core:1.7.1] 
 
     at org.apache.aries.blueprint.container.BlueprintEventDispatcher.blueprintEvent(BlueprintEventDispatcher.java:140)[83:org.apache.aries.blueprint.core:1.7.1] 
 
     at org.apache.aries.blueprint.container.BlueprintContainerImpl.doRun(BlueprintContainerImpl.java:424)[83:org.apache.aries.blueprint.core:1.7.1] 
 
     at org.apache.aries.blueprint.container.BlueprintContainerImpl.run(BlueprintContainerImpl.java:276)[83:org.apache.aries.blueprint.core:1.7.1] 
 
     at org.apache.aries.blueprint.container.BlueprintExtender.createContainer(BlueprintExtender.java:300)[83:org.apache.aries.blueprint.core:1.7.1] 
 
     at org.apache.aries.blueprint.container.BlueprintExtender.createContainer(BlueprintExtender.java:269)[83:org.apache.aries.blueprint.core:1.7.1] 
 
     at org.apache.aries.blueprint.container.BlueprintExtender.createContainer(BlueprintExtender.java:265)[83:org.apache.aries.blueprint.core:1.7.1] 
 
     at org.apache.aries.blueprint.container.BlueprintExtender.modifiedBundle(BlueprintExtender.java:255)[83:org.apache.aries.blueprint.core:1.7.1] 
 
     at org.apache.aries.util.tracker.hook.BundleHookBundleTracker$Tracked.customizerModified(BundleHookBundleTracker.java:500)[19:org.apache.aries.util:1.1.1] 
 
     at org.apache.aries.util.tracker.hook.BundleHookBundleTracker$Tracked.customizerModified(BundleHookBundleTracker.java:433)[19:org.apache.aries.util:1.1.1] 
 
     at org.apache.aries.util.tracker.hook.BundleHookBundleTracker$AbstractTracked.track(BundleHookBundleTracker.java:725)[19:org.apache.aries.util:1.1.1] 
 
     at org.apache.aries.util.tracker.hook.BundleHookBundleTracker$Tracked.bundleChanged(BundleHookBundleTracker.java:463)[19:org.apache.aries.util:1.1.1] 
 
     at org.apache.aries.util.tracker.hook.BundleHookBundleTracker$BundleEventHook.event(BundleHookBundleTracker.java:422)[19:org.apache.aries.util:1.1.1] 
 
     at org.apache.felix.framework.util.SecureAction.invokeBundleEventHook(SecureAction.java:1179)[org.apache.felix.framework-5.6.1.jar:] 
 
     at org.apache.felix.framework.EventDispatcher.createWhitelistFromHooks(EventDispatcher.java:730)[org.apache.felix.framework-5.6.1.jar:] 
 
     at org.apache.felix.framework.EventDispatcher.fireBundleEvent(EventDispatcher.java:485)[org.apache.felix.framework-5.6.1.jar:] 
 
     at org.apache.felix.framework.Felix.fireBundleEvent(Felix.java:4541)[org.apache.felix.framework-5.6.1.jar:] 
 
     at org.apache.felix.framework.Felix.startBundle(Felix.java:2172)[org.apache.felix.framework-5.6.1.jar:] 
 
     at org.apache.felix.framework.BundleImpl.start(BundleImpl.java:998)[org.apache.felix.framework-5.6.1.jar:] 
 
     at org.apache.felix.fileinstall.internal.DirectoryWatcher.startBundle(DirectoryWatcher.java:1253)[4:org.apache.felix.fileinstall:3.5.6] 
 
     at org.apache.felix.fileinstall.internal.DirectoryWatcher.startBundles(DirectoryWatcher.java:1225)[4:org.apache.felix.fileinstall:3.5.6] 
 
     at org.apache.felix.fileinstall.internal.DirectoryWatcher.doProcess(DirectoryWatcher.java:512)[4:org.apache.felix.fileinstall:3.5.6] 
 
     at org.apache.felix.fileinstall.internal.DirectoryWatcher.process(DirectoryWatcher.java:361)[4:org.apache.felix.fileinstall:3.5.6] 
 
     at org.apache.felix.fileinstall.internal.DirectoryWatcher.run(DirectoryWatcher.java:312)[4:org.apache.felix.fileinstall:3.5.6] 
 
Caused by: java.lang.NoClassDefFoundError: Could not initialize class org.elasticsearch.transport.client.PreBuiltTransportClient 
 
     at org.apache.camel.component.elasticsearch5.ElasticsearchProducer.doStart(ElasticsearchProducer.java:221) 
 
     at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61) 
 
     at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:75) 
 
     at org.apache.camel.impl.DeferServiceStartupListener.onCamelContextStarted(DeferServiceStartupListener.java:49) 
 
     at org.apache.camel.impl.DefaultCamelContext.safelyStartRouteServices(DefaultCamelContext.java:3629) 
 
     at org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRoutes(DefaultCamelContext.java:3408) 
 
     at org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:3262) 
 
     at org.apache.camel.impl.DefaultCamelContext.access$000(DefaultCamelContext.java:201) 
 
     at org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:3046) 
 
     at org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:3042) 
 
     at org.apache.camel.impl.DefaultCamelContext.doWithDefinedClassLoader(DefaultCamelContext.java:3065) 
 
     at org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:3042) 
 
     at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61) 
 
     at org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:2980) 
 
     at org.apache.camel.blueprint.BlueprintCamelContext.start(BlueprintCamelContext.java:244) 
 
     at org.apache.camel.blueprint.BlueprintCamelContext.maybeStart(BlueprintCamelContext.java:284) 
 
     at org.apache.camel.blueprint.BlueprintCamelContext.blueprintEvent(BlueprintCamelContext.java:177) 
 
     at org.apache.aries.blueprint.container.BlueprintEventDispatcher$4.call(BlueprintEventDispatcher.java:201) 
 
     at org.apache.aries.blueprint.container.BlueprintEventDispatcher$4.call(BlueprintEventDispatcher.java:199) 
 
     at java.util.concurrent.FutureTask.run(FutureTask.java:266)[:1.8.0_121] 
 
     at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)[:1.8.0_121] 
 
     at java.util.concurrent.FutureTask.run(FutureTask.java:266)[:1.8.0_121] 
 
     at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)[:1.8.0_121] 
 
     at java.util.concurrent.FutureTask.run(FutureTask.java:266)[:1.8.0_121] 
 
     at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)[:1.8.0_121] 
 
     at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)[:1.8.0_121] 
 
     at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)[:1.8.0_121] 
 
     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)[:1.8.0_121] 
 
     at java.lang.Thread.run(Thread.java:745)[:1.8.0_121]

不知道如何解决这个问题？

注：我已经尝试使用2.20中的功能，但它似乎不工作。这是问题。 I 基本上在那里使用了两个捆绑包。

Elasticsearch束mvnrepository.com/artifact/org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch/5.4.3_1

Elasticsearch客户端捆绑mvnrepository.com/artifact/org。 apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch客户端/ 5.4.3_1

为了与elasticsearch 5工作，你需要在example提到这是elasticsearch捆绑提供TransportClient
要获得第一步的TransportClient，您需要使用Elasticsearch-Client软件包中提供的PreBuiltTransportClient。
现在的问题是，它有望回到TransportClient Elasticsearch客户端没有它，也没有将其导入并给出了类未发现异常“ 造成的：抛出java.lang.ClassNotFoundException：org.elasticsearch.client .transport.TransportClient不受org.apache.servicemix.bundles.elasticsearch客户端发现[127]”

来源

2017-07-18 anna

并非一切工作/ OSGi的运行。你可以尝试深入挖掘，看看你是否可以获得比堆栈追踪更多的东西？也许检查elastichseach的源代码，并打开调试日志等，看看发生了什么。 –

这看起来是一个众所周知的问题，已经有报道，但尚未修复。 [Camel-Community]（http://camel.465427.n5.nabble.com/problem-when-using-elasticsearch5-component-with-camel-2-19-0-td5799247.html）， [Servicemix-社区]（http://servicemix.396122.n5.nabble.com/Problem-when-using-elasticsearch5-component-with-camel-2-19-0-td5724431.html） – anna

这应该从ServiceMix的和在Apache的骆驼2.20.0固定与捆绑版本5.3.2_1。

在骆驼2.19.x分支，我们具有以下特点的Karaf

https://github.com/apache/camel/blob/camel-2.19.x/platforms/karaf/features/src/main/resources/features.xml#L508-L522

虽然2.20.x分支，我们有Elasticsearch客户端捆绑太：

https://github.com/apache/camel/blob/master/platforms/karaf/features/src/main/resources/features.xml#L566-L580

您可以尝试使用Camel 2.20.0-SNAPSHOT版本。

UPDATE：

有一个JIRA问题这一点：https://issues.apache.org/jira/browse/SM-3454，我们要解决它

来源

2017-07-24 07:24:08 Oscerd

我该怎么试试2.20.0- SNAPSHOT，因为它尚未在[maven回购]（https://repo1.maven.org/maven2/org/apache/camel/karaf/apache-camel/）？ – anna

您可以在您的机器上构建源代码或使用以下存储库http://repository.apache.org/snapshots。这个存储库并不总是被更新。 – Oscerd

我已更新关于您的建议使用2.20.x的东西的问题。 – anna

骆驼elasticsearch5组件不起作用

回答

相关问题