You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Hello, I'm new to reactor... and I wanted to use it to consume from Kafka (which on the other side I know well).
So the thing is I wanted to setup a pipeline that does retry in case of error. I read in the docs that an error in reactor is a terminal operation... even when using retry and backoff the engine will resubscribe to the flux. I use this to consume from a topic, following the thread per partition example:
Hello, I'm new to reactor... and I wanted to use it to consume from Kafka (which on the other side I know well).
So the thing is I wanted to setup a pipeline that does retry in case of error. I read in the docs that an error in reactor is a terminal operation... even when using retry and backoff the engine will resubscribe to the flux. I use this to consume from a topic, following the thread per partition example:
does it result in the consumer being re-created every time there is an error (that sounds crazy to me)...?
The text was updated successfully, but these errors were encountered: