[KAFKA-2216] ConsumerMetadataRequest does not validate consumer group exists

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Not A Problem
• Component/s: core
• Assignee: Grant Henke
• Reporter: Grant Henke
• Created: 21/May/15 16:05
• Updated: 04/Feb/16 22:19
• Resolved: 04/Feb/16 22:19

Description

Currently the offset partition is found by hashing & modding the name:

// Utils.abs(group.hashCode) % config.offsetsTopicNumPartitions
val partition = offsetManager.partitionFor(consumerMetadataRequest.group)

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.