[Solved][Kafka] [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Error connecting to node min:9092 (id: 0 rack: null)

[kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Error connecting to node min:9092 (id: 0 rack: null)
java.net.UnknownHostException: min

 

우분투로 가성환경을 구성하여 카프카 서버를 기동시켜놓고 자바에서 Producer 객체를 생성한 뒤에 메세지를 Send() 하려고 했는데 

위와 같은 에러 메세지가 발생했다. 

[kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Error connecting to node min:9092 (id: 0 rack: null)

 

메세지 내용을 보니 Kafka 프로두셔가 브로커에 연결할 때 "min" 호스트를 찾을 수 없다는 내용이었다. 

 

        String topicName = "simple-topic";
        //KafkaProducer configuration setting

        Properties props = new Properties();
        //bootstrap.servers, key.serializer.class, value.serializer.class
        // props.setProperty("bootstrap.servers", "192.168.56.101:9092");
        props.setProperty(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "192.168.56.101:9092");
        props.setProperty(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
        props.setProperty(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());

 

소스는 위와 같이 구성했으며, hosts 파일에 브록커 서버가 등록되어 있지 않아 문제가 발생한거 같았다.

 

나는 맥을 사용하기에 터미널을 열어서 아래와 같이 명령어를 입력하고

sudo nano /etc/hosts

 

192.168.56.101 min hosts 를 추가해 주었다. 

그리고 메세지를 던져보니 브로커 서버에서 메세지가 정상적으로 출력되었다.