RE: Terminate Streams application from within Transformer?

2018-09-26 Thread Tim Ward
That works, thanks. Tim Ward -Original Message- From: Bill Bejeck Sent: 21 September 2018 15:06 To: users@kafka.apache.org Subject: Re: Terminate Streams application from within Transformer? Hi Tim, I wouldn't recommend System.exit(), as it won't give streams a chance to go

Re: Terminate Streams application from within Transformer?

2018-09-21 Thread Bill Bejeck
Hi Tim, I wouldn't recommend System.exit(), as it won't give streams a chance to go through a shutdown process. You can throw a RuntimeException from inside the Transformer.transform() method and I will bubble up and the Steams application will shut down. -Bill On Fri, Sep 21, 2018 at 6:59 AM Ti

Terminate Streams application from within Transformer?

2018-09-21 Thread Tim Ward
>From within a Transformer I detect an error, which is a temporary error, such >as failure to get a connection to an external microservice. A typical scenario is that Kuberbetes is starting up a bunch of pods, of which mine is one, and they come up in the wrong order. This is perfectly normal, a