Ryan Wynn

hi @raiRaiyan I believe I contributed the code that you referenced. The library will check the status on each response line item as shown above before adding the request corresponding...

@raiRaiyan I think to get the behavior you are expecting, one way to do it would be to add a 4th argument to `RetryNotify` defined [here](https://github.com/olivere/elastic/blob/29cbd5a9e9d0afc0ccc3a3f6cf907caca388b66a/retry.go#L33) which is a reset...

To clarify further, without inspecting and checking the response item lines in the commit function you get a scenario where the overall bulk request succeeds, but the response line items...

A much more direct solution would be to simply add the following line after the call to [RetryNotify]( https://github.com/olivere/elastic/blob/release-branch.v7/bulk_processor.go#L580). ```golang err := RetryNotify(commitFunc, w.p.backoff, notifyFunc) w.service.Reset() ``` Since all the...

@ssoroka thanks for trying `gtm`. I would love to add tests to this project but currently don't have the spare time to do so. If I do get some time...

I'm not sure there is a difference in Elasticsearch between an empty array and a missing field. https://www.elastic.co/guide/en/elasticsearch/reference/current/array.html > An array may contain null values, which are either replaced by...

Sorry, disregard my last comment. I thought this issue was in a different repository. I just pushed a fix for this and will create a new release for it.

Hopefully this will help... main.go ```golang package main import ( "context" "flag" "fmt" "log" "time" "github.com/rwynn/gtm" "go.mongodb.org/mongo-driver/mongo" "go.mongodb.org/mongo-driver/mongo/options" ) func readContext(ctx *gtm.OpCtx, done chan bool) { var errsDone, opsDone bool...

I think it may be related to the use of buffered channels in gtm. Try updating the readContext function I posted and give the name op to the 2 _...

Also to your previous question. With Change stream NS set, yes you will also receive changes to the collections that are happening. There are methods to check if the event...