Druid 总是尝试将 Kafka 代理解析为本地主机

Question

我在本地网络的另一台机器上有一个 Kafka 实例运行，我正试图将其导入 Druid。我的摄取规范如下所示：

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

但是霸主returns我这个错误，即使我没有尝试连接到本地主机：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 版本和原生版本（最初认为这可能是与 docker 相关的一些连接问题）。

有什么问题吗？提前致谢。

编辑：忘了说我可以确认 Kafka 在通过 kafka-console-consumer 和 kafka-console-producer 测试时正常工作。

编辑：

第一个标签图片：

连接选项卡：

Answer 1

用户 cricket_007 指出 advertised.listeners 在 Kafka 设置（server.properties 文件）下没有正确设置。设置为 PLAINTEXT://192.168.0.102:9092 确实解决了问题。

Druid 总是尝试将 Kafka 代理解析为本地主机

Druid always tries to resolve Kafka broker to localhost

apache-kafka

druid