elasticsearch和camel集成

Question

我正在尝试将camel与elasticsearch集成。在applicationContext中。xml添加了以下内容

 <route id="timer-to-console">
        <from uri="timer://foo?fixedRate=true&amp;period=10s"/>
        <transform>
           <simple>Hello Web Application, how are you?</simple>
        </transform>
        <to uri="stream:out"/>
        <to uri="elasticsearch://local"/>
    </route>

然后当我跑的时候

mvn jetty:run

我得到以下信息

veryCounter=0, firedTime=Mon Apr 21 13:14:43 PDT 2014}
BodyType            String
Body                Hello Web Application, how are you?
]

 Stacktrace
  ----------------------------------------------------------------------------------------      
 java.lang.IllegalArgumentException: operation is missing
at    org.apache.camel.component.elasticsearch.ElasticsearchProducer.process(ElasticsearchProducer.java:54)
at org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61)

我的elasticsearch在本地运行，我使用ES 1.1.1。

我需要指定什么

elasticsearch://clusterName[?options]

谢谢，

Answer 1

您必须使用elasticsearch中指定的集群名称。yml，即如果它表示群集。名称：elasticsearch123然后您必须按如下方式进行路由：

来自（“文件：data\u json？noop=true

使用本地语言对我来说根本不起作用。不幸的是，它甚至没有抛出任何使调试变得困难的错误。

还要注意转换。convertBodyTo（byte[].class）-这也是很重要的，否则Camel会将JSON文件转换为类属性（它会查找从泛型文件到映射的转换，并找到一个到属性的回退类型转换器）。当然，您也可以转换为组件支持的其他类型。

还值得一提的是，版本2.14.1的camel-elasticsearch组件依赖于org.elasticsearch： elasticsearch： 1.0.0，考虑到Elasticsearch的移动速度（当前版本是1.4.4）以及它喜欢破坏兼容性的频率，这是一个相当旧的版本。也就是说，该组件似乎可以与Elasticsearch1.4.3一起使用。

更新：GitHub上当前的主分支已将Elasticsearch升级到1.4.2版本：https://github.com/apache/camel/blob/2470023e25b8814279cbadb3ebc8002bed6d8fc8/parent/pom.xml#L144

参数/clusterNamelocal实际上意味着它将从Elasticsearch的JavaDoc（NodeBuilder.local（boolean）），查找在同一JVM中启动的Elasticsearch实例：

本地节点是使用本地（JVM级别）发现和传输的节点。将发现并与在同一JVM（实际上是类加载器）中启动的其他（本地）节点进行通信。JVM之外的节点将不会被发现。

Answer 2

快速浏览Apache Camel Elasticsearch组件页面，它们显示了以下示例：

elas公司ticsearch://local?operation=INDEX

这将索引（添加）到名为twitter的索引中，类型为tweet。您可以为indexName和indexType使用任何想要的值。

更新：再次查看Elasticsearch Camel Component留档...我认为为了使用local作为elasticsearch连接中的服务器名称，您需要运行本地Elasticsearch实例，并且集群名称为local。默认情况下，Elasticsearch配置（elasticsearch.yml）设置为使用elasticsearch的集群名称运行