[ https://issues.apache.org/jira/browse/KAFKA-9751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Boyang Chen updated KAFKA-9751: ------------------------------- Description: For use cases to create internal topics through FindCoordinator or Metadata request, receiving broker should route the topic creation request to the controller instead of handling by itself. (was: 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) > Internal topic creation should go to controller > ----------------------------------------------- > > Key: KAFKA-9751 > URL: https://issues.apache.org/jira/browse/KAFKA-9751 > Project: Kafka > Issue Type: Sub-task > Reporter: Boyang Chen > Priority: Major > > For use cases to create internal topics through FindCoordinator or Metadata > request, receiving broker should route the topic creation request to the > controller instead of handling by itself. -- This message was sent by Atlassian Jira (v8.3.4#803005)