Elasticsearch ActiveMQ River 配置答案

【问题标题】：Elasticsearch ActiveMQ River ConfigurationElasticsearch ActiveMQ River 配置
【发布时间】：2013-04-16 14:25:24
【问题描述】：

我开始配置一个 ActiveMQ 河，我已经安装了 (ActiveMQ plugin) 但我对如何使它工作感到困惑，文档是如此简短，实际上，我完全按照创建一个新的步骤河流，但我不知道要遵循哪些步骤？

注意：

我已经启动并运行了一个 ActiveMQ 服务器，我使用将消息推送到队列中的简单 JMS 应用程序。

我使用以下方法创建了一条新河流：

curl -XPUT 'localhost:9200/_river/myindex_river/_meta' -d '{
  "type" : "activemq",
  "activemq" : {
      "user" : "guest",
      "pass" : "guest",
      "brokerUrl" : "failover://tcp://localhost:61616",
      "sourceType" : "queue",
      "sourceName" : "elasticsearch",
      "consumerName" : "activemq_elasticsearch_river_myindex_river",
      "durable" : false,
      "filter" : ""
  },
  "index" : {
       "bulk_size" : 100,
       "bulk_timeout" : "10ms"
  }
}'

创建上一条河流后，我可以使用 curl -XGET 'localhost:9200/my_index/_status'，它给了我索引状态，而不是创建的河流。

请帮助我通过弹性搜索的 ActiveMQ 河流配置找到正确的道路。

【问题讨论】：

标签： elasticsearch activemq

【解决方案1】：

我在邮件列表上告诉过你。定义index.index 值或将河流的名称设置为索引名称（更简单）：

curl -XPUT 'localhost:9200/_river/my_index/_meta' -d '
{
  "type":"activemq",
  "activemq":{
    "user":"guest",
    "pass":"guest",
    "brokerUrl":"failover://tcp://localhost:61616",
    "sourceType":"queue",
    "sourceName":"elasticsearch",
    "consumerName":"activemq_elasticsearch_river_myindex_river",
    "durable":false,
    "filter":""
  },
  "index":{
    "bulk_size":100,
    "bulk_timeout":"10ms"
  }
}'

或

curl -XPUT 'localhost:9200/_river/myindex_river/_meta' -d '
{
  "type":"activemq",
  "activemq":{
    "user":"guest",
    "pass":"guest",
    "brokerUrl":"failover://tcp://localhost:61616",
    "sourceType":"queue",
    "sourceName":"elasticsearch",
    "consumerName":"activemq_elasticsearch_river_myindex_river",
    "durable":false,
    "filter":""
  },
  "index":{
    "index":"my_index",
    "bulk_size":100,
    "bulk_timeout":"10ms"
  }
}'

应该有帮助。

如果没有，请使用您在日志中看到的内容更新您的问题。

【讨论】：