[KAFKA-601] ConsumerConnector.shutdown() hangs if autocommit is enabled, and no zk available

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Auto Closed
• Affects Version/s: 0.7.2
• Component/s: clients
• Assignee: Unassigned
• Reporter: Jason Rosenberg
• Created: 05/Nov/12 20:38
• Updated: 29/Oct/17 09:32
• Resolved: 29/Oct/17 09:32

Description

Hi,

I have a situation where I want to reliably shut-down a consumer, but it seems to hang in certain conditions, namely:

• If autocommit.enabled = true
• If the current zk instance is not available

It seems that it will indefinitely try to re-create the zk connection, in order to auto-commit, before exiting, even after I've called ConsumerConnector.shutdown().

I would think that there should be a way to force it to shutdown, even under error conditions.

Jason