[
https://issues.apache.org/jira/browse/KAFKA-2216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Grant Henke resolved KAFKA-2216.
--------------------------------
Resolution: Not A Problem
No longer relevant with the new groups protocol.
> ConsumerMetadataRequest does not validate consumer group exists
> ---------------------------------------------------------------
>
> Key: KAFKA-2216
> URL: https://issues.apache.org/jira/browse/KAFKA-2216
> Project: Kafka
> Issue Type: Bug
> Components: core
> Reporter: Grant Henke
> Assignee: Grant Henke
>
> Currently the offset partition is found by hashing & modding the name:
> {quote}
> // Utils.abs(group.hashCode) % config.offsetsTopicNumPartitions
> val partition = offsetManager.partitionFor(consumerMetadataRequest.group)
> {quote}
> And then the broker for the partition is returned as the coordinator broker.
> I expected an error to be returned for a group that does not exist. If this
> is not the expectation, then updating the docs may be a result of this Jira.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)