diff --git a/go.mod b/go.mod
index 9d67b78..4894ee6 100644
--- a/go.mod
+++ b/go.mod
@@ -9,5 +9,5 @@ require (
 	github.com/mailru/easyjson v0.7.3 // indirect
 	github.com/olivere/elastic v6.2.34+incompatible
 	github.com/segmentio/kafka-go v0.3.5
-	github.com/tal-tech/go-zero v1.0.2
+	github.com/tal-tech/go-zero v1.0.3
 )
diff --git a/go.sum b/go.sum
index faeb4b9..9c8700a 100644
--- a/go.sum
+++ b/go.sum
@@ -210,8 +210,8 @@ github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UV
 github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4=
 github.com/stretchr/testify v1.5.1 h1:nOGnQDM7FYENwehXlg/kFVnos3rEvtKTjRvOWSzb6H4=
 github.com/stretchr/testify v1.5.1/go.mod h1:5W2xD1RspED5o8YsWQXVCued0rvSQ+mT+I5cxcmMvtA=
-github.com/tal-tech/go-zero v1.0.2 h1:sSQCZ5M+5cgFI9sky4FSuhZ1glEKduKgfCeoSLzuSMM=
-github.com/tal-tech/go-zero v1.0.2/go.mod h1:MZHttkq0yf8kUd3TGaGvwUpiRIw9eD2iNFFfkx4YgG4=
+github.com/tal-tech/go-zero v1.0.3 h1:B7yo8yMh27ZfEpjM7s6tPKGaLtSBufIPxTPMwjsiDxI=
+github.com/tal-tech/go-zero v1.0.3/go.mod h1:MZHttkq0yf8kUd3TGaGvwUpiRIw9eD2iNFFfkx4YgG4=
 github.com/tmc/grpc-websocket-proxy v0.0.0-20170815181823-89b8d40f7ca8/go.mod h1:ncp9v5uamzpCO7NfCPTXjqaC+bZgJeR0sMTm6dMHP7U=
 github.com/tmc/grpc-websocket-proxy v0.0.0-20171017195756-830351dc03c6/go.mod h1:ncp9v5uamzpCO7NfCPTXjqaC+bZgJeR0sMTm6dMHP7U=
 github.com/urfave/cli v1.20.0/go.mod h1:70zkFmudgCuE/ngEzBv17Jvp/497gISqfk5gWijbERA=
diff --git a/stash/stash.go b/stash/stash.go
index 9b2dca3..1c1b4a6 100644
--- a/stash/stash.go
+++ b/stash/stash.go
@@ -11,7 +11,7 @@ import (
 	"github.com/tal-tech/go-stash/stash/filter"
 	"github.com/tal-tech/go-stash/stash/handler"
 	"github.com/tal-tech/go-zero/core/conf"
-	"github.com/tal-tech/go-zero/core/lang"
+	"github.com/tal-tech/go-zero/core/logx"
 	"github.com/tal-tech/go-zero/core/proc"
 )
 
@@ -30,13 +30,13 @@ func main() {
 		elastic.SetSniff(false),
 		elastic.SetURL(c.Output.ElasticSearch.Hosts...),
 	)
-	lang.Must(err)
+	logx.Must(err)
 
 	indexFormat := c.Output.ElasticSearch.DailyIndexPrefix + dateFormat
 	var loc *time.Location
 	if len(c.Output.ElasticSearch.TimeZone) > 0 {
 		loc, err = time.LoadLocation(c.Output.ElasticSearch.TimeZone)
-		lang.Must(err)
+		logx.Must(err)
 	} else {
 		loc = time.Local
 	}
@@ -46,7 +46,7 @@ func main() {
 
 	filters := filter.CreateFilters(c)
 	writer, err := es.NewWriter(c.Output.ElasticSearch, indexer)
-	lang.Must(err)
+	logx.Must(err)
 
 	handle := handler.NewHandler(writer)
 	handle.AddFilters(filters...)