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
