Друид КроликMQ Firehose

Я пытаюсь настроить druid для работы с rabbitmq firehose, но получаю следующую ошибку от Tranquility

java.lang.IllegalArgumentException: не удалось преобразовать идентификатор типа «rabbitmq» в подтип [простой тип, класс io.druid.data.input.FirehoseFactory]

Я сделал следующее 1. Установил Druid 2. Скачал расширение druid-rabbitmq 3. Скопировал druid-rabbitmq в расширения druid 4. Скопировал jar amqp-client в druid lib 5. Добавил druid-rabbitmq в druid.extensions.loadList в common.runtime .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"
        }
      }
    }

rabbitmq druid
person bbox    schedule 01.11.2016    source источник
comment
какую версию Druid Tranquility вы используете?   -  person Nirmal Ram    schedule 03.11.2016
comment
Я использую imply 1.3.0, но я думаю, что Tranquility предназначен для проталкивания потока, а пожарный шланг используется для вытягивания потока, поэтому я думаю, что это была проблема. Итак, теперь я создал узел реального времени, и он работает нормально. Мне также пришлось скопировать файл lyra jar в каталог druid lib. Теперь я могу опубликовать данные из Rabbit, и они были вставлены в druid, и я могу запросить данные, но проблема в том, что в Rabbit сообщение все еще отображается как неподтвержденное. Есть идеи?   -  person bbox    schedule 03.11.2016

Ответы (1)


arrow_upward
0
arrow_downward

Я использую imply 1.3.0, но я думаю, что Tranquility предназначен для проталкивания потока, а пожарный шланг используется для вытягивания потока, поэтому я думаю, что это была проблема. Итак, теперь я создал узел реального времени, и он работает нормально. Мне также пришлось скопировать файл lyra jar в каталог druid lib. Теперь я могу опубликовать данные из Rabbit, и они были вставлены в druid, и я могу запросить данные, но проблема в том, что в Rabbit сообщение все еще отображается как неподтвержденное. Есть идеи?

person bbox    schedule 03.11.2016
comment
Можете ли вы опубликовать окончательную спецификацию в реальном времени? Я пытаюсь воссоздать что-то подобное, и это было бы невероятно полезно. - person dj_bushido; 26.10.2017