From 4952aca9683b104a45a5c4ae886128c25af439fe Mon Sep 17 00:00:00 2001
From: liufugen-yewu <79236187+liufugen-yewu@users.noreply.github.com>
Date: Mon, 21 Nov 2022 16:06:05 +0800
Subject: [PATCH 1/2] Update kafka.go
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

kafkaReport组件bug修复
---
 kafkareporter/kafka.go | 13 ++++++++++++-
 1 file changed, 12 insertions(+), 1 deletion(-)

diff --git a/kafkareporter/kafka.go b/kafkareporter/kafka.go
index d9108c0..943cc62 100644
--- a/kafkareporter/kafka.go
+++ b/kafkareporter/kafka.go
@@ -85,7 +85,7 @@ func New(addrs []string, opts ...Option) (go2sky.Reporter, error) {
 			}
 		}()
 	}
-
+	go r.readBackMessage()
 	return r, nil
 }
 
@@ -297,6 +297,17 @@ func (r *kafkaReporter) Close() {
 		r.logger.Print(err)
 	}
 }
+//循环处理上报信息的结果信息，以实现kafka单次连接多次上报。
+func (r *kafkaReporter) readBackMessage() {
+	for {
+		select {
+		case <-r.producer.Successes():
+		case err := <- r.producer.Errors():
+			r.logger.Fatalf( "kafkaReport readBackMessage error detail is %s",err)
+		default:
+		}
+	}
+}
 
 func buildOSInfo() (props []*commonv3.KeyStringValuePair) {
 	processNo := tool.ProcessNo()

From 261c18729d6ca3dfd89fc4a59075eccf19473555 Mon Sep 17 00:00:00 2001
From: liufugen-yewu <79236187+liufugen-yewu@users.noreply.github.com>
Date: Thu, 24 Nov 2022 15:58:23 +0800
Subject: [PATCH 2/2] Update kafka.go

---
 kafkareporter/kafka.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/kafkareporter/kafka.go b/kafkareporter/kafka.go
index 943cc62..e6444ce 100644
--- a/kafkareporter/kafka.go
+++ b/kafkareporter/kafka.go
@@ -297,7 +297,7 @@ func (r *kafkaReporter) Close() {
 		r.logger.Print(err)
 	}
 }
-//循环处理上报信息的结果信息，以实现kafka单次连接多次上报。
+//The result information of the reported information is processed in a loop to achieve multiple reports in a single kafka connection.
 func (r *kafkaReporter) readBackMessage() {
 	for {
 		select {