I am trying to handle errors with ErrorHandler pipe in ultra.
My ultra main pipe has no i/p no o/p design(kafka snap at start and end of pipe), Here to handle errors my errorhadler is having copy snap at first place, 1 o/p of copy snap using to push data in DB and another i am keeping it opened to get async response from error pipe so that it will not wait for sql operation.
But error pipe stopped consuming docs after processing some 1024 odd docs.
As in screenshot i made all 3k doc to fail in test child pipe and send them to error pipe but only 1024 went.
Please suggest how can i get async response from this error pipe.