Hi John, bq. #1 (wait for metadata) is infinite.
Some of what you stated in this KIP has already been previously discussed in a older KIP. (KIP-266) Just for your reference. Thanks, Richard 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 >
