From f9551ebe7d20a183f31ca7ad56024b86a61b8040 Mon Sep 17 00:00:00 2001
From: zwl <1633720889@qq.com>
Date: Thu, 19 Oct 2023 17:27:55 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8Ddata=20race?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 e2e/base_test.go | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/e2e/base_test.go b/e2e/base_test.go
index 8d5d6c9..a8df3b7 100644
--- a/e2e/base_test.go
+++ b/e2e/base_test.go
@@ -756,7 +756,10 @@ func (b *TestSuite) TestMQConsumer_Consume() {
 	err = c.Close()
 	require.NoError(b.T(), err)
 	time.Sleep(5 * time.Second)
-	assert.ElementsMatch(b.T(), wantVal, genMsg(ans, false))
+	locker.Lock()
+	val := ans
+	locker.Unlock()
+	assert.ElementsMatch(b.T(), wantVal, genMsg(val, false))
 }
 
 func genMsg(msgs []*mq.Message, hasPartitionID bool) []*mq.Message {