[KAFKA-8776] Add new public method to only update assignment metadata in consumer

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: consumer
• Assignee: Unassigned
• Reporter: Jungtaek Lim
• Created: 09/Aug/19 03:34
• Updated: 09/Aug/19 03:34

Description

In KIP-266, Kafka deprecated `poll(long)` with `poll(Duration)` as former method applies no timeout on assignment metadata update. New method applies timeout value to do both "update assignment metadata" as well as "poll some records", which doesn't cover the case where caller is only interested in assignment metadata. `poll(0)` has been used as some kind of hack for such purpose (though Kafka document clarifies the behavior is not guaranteed), and there's no alternative - `poll(Duration.ZERO)` would bring timeout on updating assignment metadata.

This issue proposes a new public method to only trigger updating assignment metadata.

Please refer https://cwiki.apache.org/confluence/display/KAFKA/KIP-505%3A+Add+new+public+method+to+only+update+assignment+metadata+in+consumer for more details.