经过一番搜索后,在此帮助下找到了答案。
以下是代码
RedeemablePromise<Result> promise = RedeemablePromise.empty();kafkaProducer.send(record, (metadata, ex) -> { if (ex != null) { promise.failure(ex); } else { promise.success(created(Json.toJson(new ProduceResult()))); }});
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)