Boyang Chen created KAFKA-9751: ---------------------------------- Summary: Admin `FindCoordinator` call should go to controller instead of ZK Key: KAFKA-9751 URL: https://issues.apache.org/jira/browse/KAFKA-9751 Project: Kafka Issue Type: Sub-task Reporter: Boyang Chen
In current trunk, we are still going to use ZK for topic creation in the routing of FindCoordinatorRequest: val (partition, topicMetadata) = CoordinatorType.forId(findCoordinatorRequest.data.keyType) match { case CoordinatorType.GROUP => val partition = groupCoordinator.partitionFor(findCoordinatorRequest.data.key) val metadata = getOrCreateInternalTopic(GROUP_METADATA_TOPIC_NAME, request.context.listenerName) (partition, metadata) Which should be migrated to controller handling -- This message was sent by Atlassian Jira (v8.3.4#803005)