diff --git a/app/mix/dao/elasticsearch.go b/app/mix/dao/elasticsearch.go index ca393f28..bc09c239 100644 --- a/app/mix/dao/elasticsearch.go +++ b/app/mix/dao/elasticsearch.go @@ -53,7 +53,9 @@ func (es *ElasticSearch) CreateStreamerAcct(ctx *gin.Context, streameraccts []*d for _, streameracct := range streameraccts { bulk.Add(elastic.NewBulkCreateRequest().Doc(streameracct)) } - _, err := bulk.Do(ctx) + logger.Info("bulk: %v", bulk) + rsp, err := bulk.Do(ctx) + logger.Info("rsp: %v", rsp) return err }