Kafka异步发布失败，是否抛出异常？

Question

下面是我将代码发布到kafka的代码。

我需要知道在以下情况下会发生什么，

1. 当异步发送消息并且没有收到所有消息的确认时，它会在客户端抛出异常吗？

2. 当消息在缓冲区中但从未发送到kafka时会发生什么，它会引发异常吗？

3. 在具有重试= 1和重试= 0的异步发布中会发生什么？

4. send（）调用之后，将其添加到缓冲区并返回，现在，如果无法将其发送到kafka，它会引发异常吗？

5. 我有一种情况，它未能发布到kafka，但没有得到任何例外。为什么？

// Kafka

 Properties prop = new Properties();
    prop.put("bootstarp.servers","");
    prop.put("acks","all");
    prop.put("retries",0); 


    KafkaProducer connection = null;
            try { 
            connection = new KafkaProducer<String, byte[]>(props);
            msg.setTopic(topic);
            msg.setDate(new Date());
            connection.send(msg);
            } catch() {

            } finally {
            connection.close();
            }

Answer 1

您有解决方案吗？我也有类似的问题。

谢谢，Amiya