The enhancement gives SinkTaskContext state information. Have you thought of exposing the state retrieval as an enum (initially with two values) ?
Thanks On Wed, Mar 28, 2018 at 6:55 PM, Matt Farmer <m...@frmr.me> wrote: > Hello all, > > I am proposing KIP-275 to improve Connect's SinkTaskContext so that Sinks > can be informed > in their preCommit hook if the hook is being invoked as a part of a > rebalance or Connect > shutdown. > > The KIP is here: > https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=75977607 > > Please let me know what feedback y'all have. Thanks! >
