0

我正在尝试设置 druid 以使用 rabbitmq firehose，但从 Tranquility 收到以下错误

java.lang.IllegalArgumentException：无法将类型 id 'rabbitmq' 解析为 [简单类型，类 io.druid.data.input.FirehoseFactory] ​​的子类型

我做了以下 1. 安装 Druid 2. 下载扩展 druid-rabbitmq 3. 将 druid-rabbitmq 复制到 druid 扩展 4. 将 amqp-client jar 复制到 druid lib 5. 将 druid-rabbitmq 添加到 common.runtime 中的 druid.extensions.loadList .properties 6. 在 Tranquility server.json 配置中添加了 firehose 配置

"ioConfig" : {
      "type" : "realtime",
      "firehose" : {
        "type" : "rabbitmq",
        "connection" : {
          "host": "localhost",
          "port": "5672",
          "username": "blackbox",
          "password": "blackbox",
          "virtualHost": "blackbox-vhost",
          "uri": "amqp://localhost:5672/blackbox-vhost"
        },
        "config" : {
          "exchange": "test-exchange",
          "queue" : "test-q",
          "routingKey": "#",
          "durable": "true",
          "exclusive": "false",
          "autoDelete": "false",
          "maxRetries": "10",
          "retryIntervalSeconds": "1",
          "maxDurationSeconds": "300"
        }
      }
    }
4

1 回答 1

0

我正在使用 imply 1.3.0，但我认为 Tranquility 用于流推，而消防软管用于流拉，所以我认为这是问题所在。所以现在我创建了一个实时节点，它运行良好。我还必须将 lyra jar 文件复制到 druid lib 目录中。现在我可以从兔子发布数据并将其插入德鲁伊，我可以查询数据，但问题是在兔子中消息仍然显示为未确认。任何想法？

于 2016-11-03T13:16:11.660 回答