Hi Radai,
It seems reasonable to me.
best,
Colin
On Mon, Oct 21, 2019, at 09:52, radai wrote:
> yet another bump.
>
> can we please have a vote if there are no objections ?
>
> On Wed, Sep 25, 2019 at 1:28 PM radai <radai.rosenbl...@gmail.com> wrote:
> >
> > bump.
> >
> > so if no more concerns, can we move to a vote on this ?
> >
> > On Fri, Sep 13, 2019 at 10:05 AM radai <radai.rosenbl...@gmail.com> wrote:
> > >
> > > we have a lot of processes that need a time-bounded checkpoint logic.
> > >
> > > the standard use case is some consume-process-produce logic of the
> > > following form:
> > >
> > > while (alive) {
> > > data = consumer.poll()
> > > output = process(data)
> > > producer.send(output)
> > >
> > > if (System.millis() > nextCheckpoint) {
> > > nextCheckpoint = System.millis() + 5 minutes;
> > > if (!producer.flush(30 seconds) || !consumer.commitSync(30
> > > seconds)) {
> > > //unable to checkpoint within timeout, die (or at least raise
> > > some alarm)
> > > }
> > > }
> > > }
> > >
> > > an unbounded flush could cause the consumer to be considered dead and
> > > send the whole app into rebalance storms, so we'd really love to be
> > > able to put a time bound on it.
> > >
> > > im also fine with rethrowing InterruptedException
> > >
> > > On Thu, Sep 12, 2019 at 3:46 PM Colin McCabe <cmcc...@apache.org> wrote:
> > > >
> > > > Hi Radai,
> > > >
> > > > Thanks for the KIP. Sounds interesting. I assume that if an
> > > > InterruptedException were caught, that would be rethrown, rather than
> > > > returning false? It might be good to specify that. Can you give an
> > > > example of how this would be used?
> > > >
> > > > best,
> > > > Colin
> > > >
> > > >
> > > > On Thu, Sep 12, 2019, at 15:26, radai wrote:
> > > > > bump.
> > > > >
> > > > > if no one has any comments on this can we initiate a vote?
> > > > >
> > > > > On Tue, Sep 3, 2019 at 8:28 AM KUN DU <dukun...@gmail.com> wrote:
> > > > > >
> > > > > > Hi,
> > > > > >
> > > > > > I would like to start discussion on KIP-514 that proposes we add a
> > > > > > bounded flush() API to producer.
> > > > > >
> > > > > > Link to the KIP:
> > > > > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-514%3A+Add+a+bounded+flush%28%29+API+to+Kafka+Producer
> > > > > >
> > > > > > Suggestions and feedback are welcome!
> > > > > >
> > > > > > Thanks,
> > > > > > Kun
> > > > >
>
