producer.send(message, new SendCallback(){ onSuccess(){} onException(){} })
注意:官方例子:如果异步发送消息,调用producer.shutdown()后会失败
异步发送:不会重试,发送总次数等于1
本文作者为DBC,转载请注明。
producer.send(message, new SendCallback(){ onSuccess(){} onException(){} })
注意:官方例子:如果异步发送消息,调用producer.shutdown()后会失败
异步发送:不会重试,发送总次数等于1
本文作者为DBC,转载请注明。