我有两个kafka代理：server1:9092和server2:9092我正在使用一个java客户机向这个集群发送消息，代码如下：

@Test
public void sendRecordToTopic() throws InterruptedException, ExecutionException {

    //See at http://kafka.apache.org/documentation.html#newproducerconfigs
    Properties props = new Properties();
    props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,
            "server1:9092,server2:9092");
    props.put(ProducerConfig.ACKS_CONFIG, "1");
    props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringSerializer");
    props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringSerializer");

    KafkaProducer<String, String> producer = new KafkaProducer<String, String>(props);

    ProducerRecord<String, String> myRecord =
            new ProducerRecord<String, String>("my-replicated-topic", "test", "someValue");

    boolean syncSend = true;

    if (syncSend) {
        //Synchronously send
        producer.send(myRecord).get();
    } else {
        //Asynchronously send
        producer.send(myRecord);
    }
    producer.close();
}

当某个代理关闭时，测试在某些情况下会引发此异常（在此异常示例中，“server1”已关闭）：
2015-11-02 17:59:29,138 warn[org.apache.kafka.common.network.selector]server1/40.35.250.227 java.net.connectexception的i/o出错：连接被拒绝：sun.nio.ch.socketchannelimpl.checkconnect（本机方法）的sun.nio.ch.socketchannelimpl.finishconnect（socketchannelimpl）没有进一步的信息。java:717)在org.apache.kafka.common.network.selector.poll（选择器。java:238)在org.apache.kafka.clients.networkclient.poll（networkclient。java:192)在org.apache.kafka.clients.producer.internals.sender.run（sender。java:191)在org.apache.kafka.clients.producer.internals.sender.run（sender。java:122)在java.lang.thread.run（线程。java:745)