AWS EC2에서 HDP 2.4에서 HDP 2.5로 업데이트 한 후 kafka에 연결할 수 없습니다.

Question

카툰 프로듀서 프로젝트를 가상 박스를 통해 샌드 박스 2.4에 구현했지만 AWS EC2 (Hortonworks cloudbreak 사용)에서이 프로젝트를 구현했습니다. 이로 인해 HDP 2.5로 업그레이드되어 kafka 9에서 kafka 10으로 전환되었습니다. 필요한 종속성 및 IP (로컬 호스트) 변경 사항을 얻었지만 수신 중입니다. java.net.ConnectException: Connection timed out: no further information

kafkaBroker 내부 IP는 10.0.75.111이고 샘플 kafka 제작자

public void initialise() { 
    Properties props = new Properties(); 
    props.put("bootstrap.servers", "10.0.75.111:6667"); // replaced localhost 
    props.put("acks", "all"); 
    props.put("retries", 0); 
    props.put("batch.size", 16384); 
    props.put("linger.ms", 1); 
    props.put("buffer.memory", 33554432); 
    props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer"); 
    props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer"); 
    producer = new org.apache.kafka.clients.producer.KafkaProducer<Integer, String>(props); 
} 

카프카 리스너 아래 PLAINTEXT://localhost:6667

프로그램을 실행 한 후에는

803862 [kafka-producer-network-thread | producer-14] DEBUG org.apache.kafka.clients.NetworkClient - Initiating connection to node -1 at 10.0.75.111:6667. 
824863 [kafka-producer-network-thread | producer-14] DEBUG org.apache.kafka.common.network.Selector - Connection with /10.0.75.111 disconnected 
java.net.ConnectException: Connection timed out: no further information 
at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) 
at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717) 
at org.apache.kafka.common.network.PlaintextTransportLayer.finishConnect(PlaintextTransportLayer.java:51) 
at org.apache.kafka.common.network.KafkaChannel.finishConnect(KafkaChannel.java:73) 
at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:309) 
at org.apache.kafka.common.network.Selector.poll(Selector.java:283) 
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:260) 
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:229) 
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:134) 
at java.lang.Thread.run(Thread.java:745) 
824863 [kafka-producer-network-thread | producer-14] DEBUG org.apache.kafka.clients.NetworkClient - Node -1 disconnected. 

,536,913,632 아래의 오류 메시지가 반환된다 10

감사합니다.

Answer 1

AWS 설정 클러스터로 데이터를 보내는 경우 외부 IP 주소를 사용해야합니다. 그러나 네트워크에서 실행하는 경우 두 가지를 모두 사용할 수 있습니다.

귀하의 경우 네트워크 외부에서 실행중인 것 같습니다. 내부/외부의 공용 IP를 사용하여 실행 해보십시오. 그게 너를 가야 해.