我在本地网络中的另一台机器上运行了一个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"
}
}
}
}但是,即使我没有尝试连接到本地主机: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工作正常。
编辑:
第一个选项卡图像:

连接选项卡:

发布于 2019-10-11 01:34:09
用户cricket_007指出,advertised.listeners没有在Kafka设置(server.properties文件)下正确设置。将其设置为PLAINTEXT://192.168.0.102:9092肯定解决了这个问题。
https://stackoverflow.com/questions/58326780
复制相似问题