Apache Camel与Elasticsearch集成

Question

我正在从事一个使用Apache Camel和Elasticsearch的项目，我想知道Camel支持哪个版本的Elasticsearch？

我的pom.xml是这样的：

<dependencies>
<dependency>
  <groupId>org.apache.camel</groupId>
  <artifactId>camel-core</artifactId>
  <version>2.18.2</version>
</dependency>

<dependency>
  <groupId>org.apache.camel</groupId>
  <artifactId>camel-elasticsearch</artifactId>
  <version>2.18.2</version>
</dependency>

<dependency>
  <groupId>org.apache.camel</groupId>
  <artifactId>camel-xmljson</artifactId>
  <version>2.18.2</version>
</dependency>

<dependency>
  <groupId>xom</groupId>
  <artifactId>xom</artifactId>
  <version>1.2.5</version>
</dependency>

但是当我想将文件路由到elasticsearch时，我遇到了以下错误：

Java语言lang.IllegalStateException：收到来自不受支持版本的消息：[2.0.0]最小兼容版本为：[5.0.0]

我发现这个异常是由于使用旧版本的节点或TransportClient造成的。所以我尝试添加elasticsearch依赖项：

    <dependency>
      <groupId>org.elasticsearch</groupId>
      <artifactId>elasticsearch</artifactId>
      <version>5.1.2</version>
    </dependency>

但它给了我一个新的错误：

线程“main”java中出现异常。lang.NoClassDefFoundError:org/elasticsearch/action/WriteConsistencyLevel

所以我想知道。。Apache Camel可以使用哪个版本的ES？

尝试向elasticsearch发送数据的代码：

XmlJsonDataFormat xmlJsonFormat = new XmlJsonDataFormat();

from("file://C:/Projects/?fileName=data.xml&charset=utf-8")
    .marshal(xmlJsonFormat)
    .to("elasticsearch://clusterES?transportAddresses=127.0.0.1:9300&operation=BULK_INDEX&indexName=xml&indexType=account");

Answer 1

我认为除了骆驼弹性搜索之外，您不需要添加任何其他pom。您似乎更有可能在旧版本上运行TransportClient。您需要找到它并升级TransportClient。

https://www.elastic.co/guide/en/elasticsearch/guide/current/_transport_client_versus_node_client.html

https://discuss.elastic.co/t/received-message-from-unsupported-version-2-0-0-minimal-compatible-version-is-5-0-0/64708