下面是我向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();
}
暂无答案!
目前还没有任何答案,快来回答吧!