Charles PIERRE

Ok understood. In any case my logic is a bit more complex and so i ended up monkey patching adapted_fields in cattr - do you think it would be useful...

We just experienced the same issue on version 0.22.2-SNAPSHOT. This is a huge problem as it blocks every subsequent ingestion :(

Would be very interested to have an helper function on the model of what scan does ! Did you end up opening a PR on this ?

@andreycizov Same user case here. Did you find a way to solve your problem ?

In celery you have a setting to restart your worker after a certain amount of executed tasks. May be useful to you. Doing some test, i see the memory increase...

Hello, I think this would be a valuable addition as it is a very common use-case nowadays

I think this is a great addition to the library. Right now, messages a silently dropped after a connection failure