code: func (b *Broker) CreateTopic(topics []proto.TopicInfo, timeout time.Duration, validateOnly bool) (*proto.CreateTopicsResp, error) {
  	b.mu.Lock()
  	defer b.mu.Unlock()
  	var resp *proto.CreateTopicsResp
  	err := b.callOnClusterController(func(c *connection) error {
  		var err error
  		req := proto.CreateTopicsReq{
  			Timeout:              timeout,
  			CreateTopicsRequests: topics,
  			ValidateOnly:         validateOnly,
  		}
  		resp, err = c.CreateTopic(&req)
  		return err
  	})
  	return resp, err
  }
docs: // CreateTopic request topic creation