(hudi) branch master updated: [HUDI-6094] make utilities kafka send call from async to sync (#8489)

[vb...@apache.org]

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 <du...@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 <du...@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);