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)

Reply via email to