This is an automated email from the ASF dual-hosted git repository. vbalaji pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push: new dce367f3f73 [HUDI-6094] make utilities kafka send call from async to sync (#8489) dce367f3f73 is described below commit dce367f3f7310de85302572c1b6999e3af5cada9 Author: Du Bin <dubin...@gmail.com> AuthorDate: Sun Dec 10 03:04:52 2023 +0800 [HUDI-6094] make utilities kafka send call from async to sync (#8489) Co-authored-by: dubin08 <dubi...@kuaishou.com> --- .../hudi/utilities/callback/kafka/HoodieWriteCommitKafkaCallback.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hudi-utilities/src/main/java/org/apache/hudi/utilities/callback/kafka/HoodieWriteCommitKafkaCallback.java b/hudi-utilities/src/main/java/org/apache/hudi/utilities/callback/kafka/HoodieWriteCommitKafkaCallback.java index 61e62fa3605..75cc9df86d3 100644 --- a/hudi-utilities/src/main/java/org/apache/hudi/utilities/callback/kafka/HoodieWriteCommitKafkaCallback.java +++ b/hudi-utilities/src/main/java/org/apache/hudi/utilities/callback/kafka/HoodieWriteCommitKafkaCallback.java @@ -65,7 +65,7 @@ public class HoodieWriteCommitKafkaCallback implements HoodieWriteCommitCallback String callbackMsg = HoodieWriteCommitCallbackUtil.convertToJsonString(callbackMessage); try (KafkaProducer<String, String> producer = createProducer(hoodieConfig)) { ProducerRecord<String, String> record = buildProducerRecord(hoodieConfig, callbackMsg); - producer.send(record); + producer.send(record).get(); LOG.info("Send callback message succeed"); } catch (Exception e) { LOG.error("Send kafka callback msg failed : ", e);