update go-zero

@@ -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
 )

@@ -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=

@@ -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...)