From 98eb7a6086fcd7aca8308fa5d3b45229d2bb7400 Mon Sep 17 00:00:00 2001
From: Raven <ravenzz@qq.com>
Date: Fri, 9 Aug 2019 09:50:05 +0800
Subject: [PATCH] =?UTF-8?q?currentOffsets=20=E5=B9=B6=E5=8F=91=E8=AF=BB?=
 =?UTF-8?q?=E5=86=99=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 reader/kafka/kafka.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/reader/kafka/kafka.go b/reader/kafka/kafka.go
index ce9be301c..e60c96aac 100644
--- a/reader/kafka/kafka.go
+++ b/reader/kafka/kafka.go
@@ -246,7 +246,9 @@ func (r *Reader) SyncMeta() {
 
 func (r *Reader) markOffset() {
 	r.lock.Lock()
+	r.statsLock.Lock()
 	defer r.lock.Unlock()
+	defer r.statsLock.Unlock()
 	for topic, partOffset := range r.currentOffsets {
 		if partOffset == nil {
 			continue