Связь отказалась при попытке подключения к Kafka в AWS EC2

Question

У меня есть экземпляр AW2 EC2 ubuntu, где он работает с зоопарком и кафкой. Я хочу подключиться к kafka с моего компьютера, поэтому у меня есть приложение Java, где я делаю соединение с помощью kafka api. При запуске приложения (из Eclipse) я получаю следующее сообщение об ошибке:

log4j:WARN No appenders could be found for logger (kafka.consumer.SimpleConsumer). 
log4j:WARN Please initialize the log4j system properly. 
Exception in thread "Timer-0" java.net.ConnectException: Connection refused 
at sun.nio.ch.Net.connect0(Native Method) 
at sun.nio.ch.Net.connect(Net.java:484) 
at sun.nio.ch.Net.connect(Net.java:476) 
at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:675) 
at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:49) 
at kafka.consumer.SimpleConsumer.getOrMakeConnection(SimpleConsumer.scala:186) 
at kafka.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:79) 
at kafka.javaapi.consumer.SimpleConsumer.fetch(SimpleConsumer.scala:43) 

Похоже, эти строки бросали ошибку:

FetchRequest req = new FetchRequest("test", 0, offset, 1000); 
ByteBufferMessageSet messageSet = simpleConsumer.fetch(req); 

Кроме того, в консоли это говорит о log4j. У меня есть файл log4j.properties в экземпляре с другими конфигурационными файлами kafka. Я не знаю, вызывает ли это ошибку, или что-то другое из конфигурации. Я попытался изменить hostname на мой публичный IP-адрес в server.properties и тот же с broker.list в producer.properties.

Я использую версию kafka 0.7.2.

Answer 1

Решено. В моем коде была строка, пытающаяся подключиться к localhost вместо обычного IP-адреса экземпляра.