From 092853d44c09ff1ffb4bdadf3d813998ecc77161 Mon Sep 17 00:00:00 2001
From: Newnius <newnius.cn@gmail.com>
Date: Tue, 26 May 2020 09:42:06 +0800
Subject: [PATCH] bugfix

---
 src/collector.go | 18 +++++++++---------
 1 file changed, 9 insertions(+), 9 deletions(-)

diff --git a/src/collector.go b/src/collector.go
index 41ab27d..7b0684d 100644
--- a/src/collector.go
+++ b/src/collector.go
@@ -54,15 +54,15 @@ func (collector *Collector) init(conf Configuration) {
 			go func(sarama.PartitionConsumer) {
 				defer collector.wg.Done()
 				for msg := range pc.Messages() {
-					var nodeStatus NodeStatus
-					err = json.Unmarshal([]byte(string(msg.Value)), &nodeStatus)
-					if err != nil {
-						log.Warn(err)
-						continue
-					}
-					go func(node NodeStatus) {
-						InstanceOfResourcePool().update(node)
-					}(nodeStatus)
+					go func(msg *sarama.ConsumerMessage) {
+						var nodeStatus NodeStatus
+						err = json.Unmarshal([]byte(string(msg.Value)), &nodeStatus)
+						if err != nil {
+							log.Warn(err)
+							return
+						}
+						InstanceOfResourcePool().update(nodeStatus)
+					}(msg)
 				}
 
 			}(pc)