首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >Druid总是尝试将Kafka代理解析为localhost

Druid总是尝试将Kafka代理解析为localhost
EN

Stack Overflow用户
提问于 2019-10-10 23:51:23
回答 1查看 716关注 0票数 0

我在本地网络中的另一台机器上运行了一个Kafka实例,我正尝试将其注入到Druid中。我的摄取规范是这样的:

代码语言:javascript
复制
{
  "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"
      }
    }
  }
}

但是,即使我没有尝试连接到本地主机: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-console-consumer和kafka-console-producer`测试时确认Kafka工作正常。

编辑:

第一个选项卡图像:

连接选项卡:

EN

回答 1

Stack Overflow用户

回答已采纳

发布于 2019-10-11 01:34:09

用户cricket_007指出,advertised.listeners没有在Kafka设置(server.properties文件)下正确设置。将其设置为PLAINTEXT://192.168.0.102:9092肯定解决了这个问题。

票数 1
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/58326780

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档