Друид всегда пытается разрешить брокера Kafka для localhost - PullRequest
Новая
       25

Друид всегда пытается разрешить брокера Kafka для localhost

0 голосов
/ 10 октября 2019

У меня есть экземпляр Kafka, работающий на другой машине в моей локальной сети, которую я пытаюсь внедрить в Друид. Моя спецификация приема выглядит следующим образом: 

{
  "type": "kafka",
  "ioConfig": {
    "type": "kafka",
    "consumerProperties": {
      "bootstrap.servers": "192.168.0.102:9092"
    },
    "topic": "metrics"
  },
  "tuningConfig": {
    "type": "kafka"
  },
  "dataSchema": {
    "dataSource": "metrics",
    "granularitySpec": {
      "type": "uniform",
      "segmentGranularity": "HOUR",
      "queryGranularity": "HOUR"
    },
    "parser": {
      "parseSpec": {
        "format": "json"
      }
    }
  }
}

Но повелитель возвращает мне эту ошибку, хотя я не пытаюсь подключиться к localhost: org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-6, groupId=kafka-supervisor-bebmfiod] Connection to node 0 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.

Когда я ставлю что-то вроде Google.com: 9092 выдает ошибку, что метаданные темы не могут быть найдены.

IP-адрес может быть разрешен на компьютере Druid (можно подтвердить с помощью ping). Версия Друида 0.16.0.

Я боролся с этой ошибкой в ​​течение нескольких дней. Я попробовал как версию Druid Docker, так и нативную (изначально думал, что это может быть проблема с подключением, связанная с докером).

Что может быть не так? Заранее спасибо.

Редактировать: забыл упомянуть, я могу подтвердить, что Кафка работает правильно при тестировании через kafka-console-consumer и kafka-console -roduction`.

Редактировать:

Изображение первой вкладки:

enter image description here

Подключение вкладки:

enter image description here

1 Ответ

1 голос
/ 10 октября 2019

Пользователь cricket_007 указал, что advertised.listeners не был правильно настроен в настройках Kafka (файл server.properties). Установка его в PLAINTEXT: //192.168.0.102: 9092 наверняка решит проблему.

...