diff --git a/reader/message_client/message_client.go b/reader/message_client/message_client.go
index 71e8bcf261..7a2a9add89 100644
--- a/reader/message_client/message_client.go
+++ b/reader/message_client/message_client.go
@@ -42,11 +42,7 @@ type MessageClient struct {
 }
 
 func (mc *MessageClient) GetTimeNow() uint64 {
-	msg, ok := <-mc.timeSyncCfg.TimeSync()
-	if !ok {
-		fmt.Println("cnn't get data from timesync chan")
-	}
-	return msg.Timestamp
+	return mc.timestampBatchEnd
 }
 
 func (mc *MessageClient) TimeSyncStart() uint64 {