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
 }