Jungtaek Lim created KAFKA-8776:
-----------------------------------

             Summary: Add new public method to only update assignment metadata 
in consumer
                 Key: KAFKA-8776
                 URL: https://issues.apache.org/jira/browse/KAFKA-8776
             Project: Kafka
          Issue Type: Improvement
          Components: consumer
            Reporter: Jungtaek Lim


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.



--
This message was sent by Atlassian JIRA
(v7.6.14#76016)

Reply via email to