Synchronous Kafka Producer-如何确保在调用future get方法后成功地将消息传递给Kafk

Question

try{
RecordMetadata d = producer.send(message).get()
if(d.hasoffset()){
//only way to ensure kafka was sent??
}}
catch (Exception e){
//or does this alone guarentee the message was sent 
}

catch异常是否单独确保消息已发送，或者如果语句检查需要

Answer 1

您应该设置acks=1或acks=all以确保代理获取消息。

之后，如果.get()没有抛出异常，那么代理将拥有该记录。

您还需要确保主题上的min.insync.replicas至少为1。