[KAFKA-1848] Checking shutdown during each iteration of ZookeeperConsumerConnector

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.9.0.0
• Assignee: Aditya Auradkar
• Reporter: Aditya Auradkar
• Reviewer: Guozhang Wang
• Created: 08/Jan/15 18:40
• Updated: 29/Mar/15 23:43
• Resolved: 22/Jan/15 01:26

Description

In ZookeeperConsumerConnector the syncedRebalance() method checks the isShuttingDown flag before it triggers a rebalance. However, it does not recheck the same value between successive retries which is possible if the consumer is shutting down.

This acquires the rebalanceLock and blocks shutdown from completing.