schandr created KAFKA-1345:
------------------------------
Summary: java API to shutdown the connector by using a
consumergroup id
Key: KAFKA-1345
URL: https://issues.apache.org/jira/browse/KAFKA-1345
Project: Kafka
Issue Type: New Feature
Reporter: schandr
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.
--
This message was sent by Atlassian JIRA
(v6.2#6252)
