From c54d47dea823430321958f635c2e0885a871580e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=BB=84=E6=B5=B7?= <10402852@qq.com>
Date: Wed, 10 May 2023 14:46:05 +0800
Subject: [PATCH] 'commit'

---
 src/main/java/UnitTest/KafkaProductorTest.java | 16 +++++++++++++---
 1 file changed, 13 insertions(+), 3 deletions(-)

diff --git a/src/main/java/UnitTest/KafkaProductorTest.java b/src/main/java/UnitTest/KafkaProductorTest.java
index 341de17..3c70959 100644
--- a/src/main/java/UnitTest/KafkaProductorTest.java
+++ b/src/main/java/UnitTest/KafkaProductorTest.java
@@ -56,9 +56,19 @@ public class KafkaProductorTest {
                     , 0, "HuangHai_" + i, "{\"id\":" + i + ",\"name\"=\"HuangHai_" + i + "\"}");
 
             //等待消息发送成功的同步阻塞方法
-            RecordMetadata metadata = producer.send(producerRecord).get();
-            System.out.println("同步方式发送消息结果：" + "topic-" + metadata.topic() + "|partition-"
-                    + metadata.partition() + "|offset-" + metadata.offset() + "|" + i);
+            //RecordMetadata metadata = producer.send(producerRecord).get();
+            //System.out.println("同步方式发送消息结果：" + "topic-" + metadata.topic() + "|partition-"
+            //+ metadata.partition() + "|offset-" + metadata.offset() + "|" + i);
+
+            // 异步发送消息
+            producer.send(producerRecord, (metadata, exception) -> {
+                if (exception != null) {
+                    System.err.println("异步发送消息失败：" + exception.getMessage());
+                } else {
+                    System.out.println("异步方式发送消息结果：" + "topic-" + metadata.topic() + "|partition-"
+                    + metadata.partition() + "|offset-" + metadata.offset());
+                }
+            });
         }
         producer.close();
     }