[KAFKA-1345] java API to shutdown the connector by using a consumergroup id

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Not A Problem
• Assignee: Unassigned
• Reporter: schandr
• Created: 28/Mar/14 02:53
• Updated: 28/Mar/14 16:47
• Resolved: 28/Mar/14 16:47

Description

Is there a way to close the consumerIterator(stream), clean up the associated threads by doing a look up on the consumerGroupId? This would help in use cases where the consumption and sending happens in different threads with different protocols. And if the sending thread is shutdown, the sending thread might want to close the consumption thread.