diff --git a/opensearch/client.go b/opensearch/client.go index 0292dec..f5e3beb 100644 --- a/opensearch/client.go +++ b/opensearch/client.go @@ -184,6 +184,8 @@ func (c *Client) sendLoop(ctx context.Context) { return } + logger.Println("log send bulk failed. retry :", respbody.Items) + var retry [][]byte for i, item := range respbody.Items { if item.Create.Status < 400 {