[KAFKA-2615] Poll() method is broken wrt time

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Implemented
• Affects Version/s: 0.8.2.1
• Fix Version/s: 0.9.0.0
• Component/s: clients, consumer, producer
• Labels: patch
• Assignee: Eno Thereska
• Reporter: Eno Thereska
• Reviewer: Guozhang Wang
• Created: 06/Oct/15 19:11
• Updated: 26/Jan/17 03:21
• Resolved: 26/Jan/17 03:21

Description

Initially reported by ewencp and discussed with hachikuji. In NetworkClient.java, the poll() method receives as input a "now" parameter, does a whole bunch of work (e.g., selector.poll()) and then keeps using "now" in all the subsequent method calls.

Passing Time everywhere instead of "now" is a potential fix, but might be expensive since it's a new system call.

Issue Links

• relates to: KAFKA-2677 Coordinator disconnects not propagated to new consumer