bq. This method will continue to return an empty collection if it doesn't complete phase #2 within the timeout. If phase #1 times out, poll will throw a TimeoutException.
It seems response from the new poll method depends on which phase it is in prior to the timeout. Wouldn't it be cleaner if TimeoutException is thrown regardless of the phase it is in ? Cheers On Tue, Apr 17, 2018 at 11:08 AM, John Roesler <j...@confluent.io> wrote: > Hello all, > > I am proposing KIP-288 to improve the semantics of Consumer.poll() w.r.t. > the timeout parameter and to add a new method for blocking for assignment > only. > > Please find the details here: > https://cwiki.apache.org/confluence/display/KAFKA/KIP- > 288%3A+Consumer.poll%28%29+timeout+semantic+change+and+ > new+waitForAssignment+method > > Please let me know what you think! > > Thanks, > -John >
