Druide RabbitMQ Firehose

Question

Je suis en train de Druid de configuration pour travailler avec rabbitmq firehose mais obtenir l'erreur suivante de Tranquility

java.lang.IllegalArgumentException: Impossible de résoudre dans un sous-type de type id 'RabbitMQ' de [type simple , classe io.druid.data.input.FirehoseFactory]

je l'ai fait ce qui suit 1. Druide installé 2. extension Downloaded Druid-rabbitmq 3. Copié-Druid rabbitmq dans les extensions Druid 4. Copié AMQP-client jar à druid lib 5. Ajouté druid-rabbitmq dans druid.extensions.loadList dans common.runtim e.properties 6. Dans la configuration Tranquilité server.json ajouté la configuration 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" 
     } 
     } 
    } 

Answer 1

J'utilise implique 1.3.0, mais je pense que Tranquility est pour le flux pousser tandis qu'un firehose est utilisé pour le flux tirant donc je pense c'était le problème. Alors maintenant, j'ai créé un nœud en temps réel et ça fonctionne bien. J'ai aussi dû copier le fichier lyra jar dans le répertoire druid lib. Maintenant, je peux publier des données à partir de lapin et il a été inséré dans le druide et je peux interroger les données mais le problème est que dans le lapin le message est toujours montré comme non saccagé. Une idée?