[
https://issues.apache.org/jira/browse/KAFKA-1345?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13950933#comment-13950933
]
Neha Narkhede commented on KAFKA-1345:
--------------------------------------
Currently, one consumer instance is associated only with one group.id. So you
will have to keep track of consumer instances and their group ids in order to
invoke shutdown() on the right instance.
> 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)
