AWS EC2でKafkaに接続しようとしているときに接続が拒否されました

Question

私には、zookeeperとkafkaを実行しているAWS EC2 ubuntuインスタンスがあります。私は私のコンピュータからkafkaに接続したいので、私はkafka apiを使って接続を行うJavaアプリケーションを持っています。私は（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

解決済みです。私のコードにインスタンスpublic IPの代わりにlocalhostに接続しようとする行がありました。