Grant Henke created KAFKA-2216:
----------------------------------
Summary: 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)