ドルイドRabbitMQの消防ホース

Question

私はのRabbitMQ消防ホースで動作するように設定ウイザードしようとしているが、静寂

java.lang.IllegalArgumentExceptionがから次のエラーを取得しています：[単純型のサブタイプにid型「のRabbitMQ」を解決できませんでした。 、クラスio.druid.data.input.FirehoseFactory] ​​

私は、次の 1.インストールドルイド 2.ダウンロードした拡張子ドルイド-RabbitMQの 3. 4.コピーしたAMQPクライアントドルイドの拡張機能にドルイド-のRabbitMQをコピーしましたjruからドルイドライブラリへ 5. common.runtimのdruid.extensions.loadListにdruid-rabbitmqを追加しましたe.properties静寂のserver.json構成で 6.私は1.3.0を意味するものでは使ってい

"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" 
     } 
     } 
    } 

Answer 1

消防ホース設定を追加しましたが、私は消防ホースの流れがそうだと思い引くために使用されている間静寂を押しストリームのためだと思いますこれが問題でした。だから私はリアルタイムのノードを作成し、それは正常に動作しています。私もlyra jarファイルをdruid libディレクトリにコピーしなければなりませんでした。今、私はウサギからのデータを公開することができ、そのデータはドルイドに挿入され、データを照会することができますが、ウサギではまだメッセージは表示されません。何か案が？