是的，如果Kafka不可用，该.send()呼叫将失败，但是如果您异步发送它，则不会通知任何人。您可以指定将来最终完成时要执行的回调。完整的接口规范在这里：https
:
//kafka.apache.org/20/javadoc/org/apache/kafka/clients/producer/Callback.html

从此处的官方Kafka
Javadoc：https
:
//kafka.apache.org/20/javadoc/index.html?
org/apache/kafka/clients/producer/
KafkaProducer.html

完全非阻塞的用法可以利用Callback参数提供将在请求完成后调用的回调。

>       ProducerRecord<byte[],byte[]> record = new
> ProducerRecord<byte[],byte[]>("the-topic", key, value);
>           producer.send(myRecord,
>                new Callback() {
>                    public void onCompletion(RecordMetadata metadata,
> Exception e) {
>                        if(e != null) {
>                           e.printStackTrace();
>                        } else {
>                           System.out.println("The offset of the record we
> just sent is: " + metadata.offset());
>                        }
>                    }
>                });