kafka异步发布失败案例,是否抛出异常?

ldioqlga  于 2021-06-08  发布在  Kafka
关注(0)|答案(0)|浏览(209)

下面是我向Kafka发布消息的代码。
我需要知道在下面的情况下会发生什么,
当消息异步发送并且没有从所有relicas获得ack时,它是否在客户端抛出异常?
当消息在缓冲区中但从未发送到kafka时会发生什么,它会引发异常吗?
在retries=1和retries=0的异步发布中会发生什么?
在send()调用之后,它被添加到缓冲区并返回,现在如果它不能发送到kafka,它会抛出异常吗?
我有一个案例,它没有发布到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();
            }

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题