diff --git a/kafkareporter/kafka.go b/kafkareporter/kafka.go
index d9108c0..e6444ce 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)
 	}
 }
+//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 {
+		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()