[ 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)