You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "schandr (JIRA)" <ji...@apache.org> on 2014/03/28 03:53:14 UTC

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

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)