apache-kafka - java.io.IOException: kafka のピアによって接続がリセットされました

Question

ubuntu ボックスにインストールされた kafka_2.10-0.8.1.1 の Java API を使用しており、High Level Consumer を実行するとjava.io.IOException: Connection reset by peerを取得しています。kafka-console-consumer.sh コマンドでは問題なく動作しますが、Java API では動作しません