diff --git a/protocol/kafka_sarama/v2/sender_test.go b/protocol/kafka_sarama/v2/sender_test.go
index 4aeec39cc..cdb1e02a8 100644
--- a/protocol/kafka_sarama/v2/sender_test.go
+++ b/protocol/kafka_sarama/v2/sender_test.go
@@ -74,6 +74,8 @@ func (s *syncProducerMock) AbortTxn() error {
 }
 
 func (s *syncProducerMock) TxnStatus() sarama.ProducerTxnStatusFlag {
+	s.lock.Lock()
+	defer s.lock.Unlock()
 	return s.status
 }