Kafka 啟動報錯java.io.IOException: Can't resolve address.

阿里雲上 部署Kafka 啟動報錯java.io.IOException: Can't resolve address.

本地調試的,報錯

需要在本地添加阿里雲主機的 host 映射

 

linux kafka server 192.168.0.141 hostname bogon

在windows

java 代碼

 

package myzookeeper;

 

import java.util.Properties;

 

import org.apache.kafka.clients.producer.KafkaProducer;

import org.apache.kafka.clients.producer.Producer;

import org.apache.kafka.clients.producer.ProducerRecord;

 

public class myCustomer {

 

public static void  main(String[] args) {

Properties props = new Properties();  

        props.put("bootstrap.servers", "192.168.0.141:9092");  

        props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");  

        props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");  

        Producer producer = new KafkaProducer<>(props);  

        producer.send(new ProducerRecord<>("mytopic", "axxxx", "axxxx"));

        System.out.println("1");

        producer.close();  

}

}

 

 

報錯 Error connecting to node 0 at bogon:9092:

不能解析bogon

kafka 連接原理

首先連接 192.168.0.141:9092

再連接返回的host.name = bogon,

最后繼續連接advertised.host.name=bogon

解決辦法

添加window解析

hosts 文件增加 

192.168.0.141 bogon

用cmd ping bogon 試試如果可以ping通即可。