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)