code: func (c *connection) CreateTopic(req *proto.CreateTopicsReq) (*proto.CreateTopicsResp, error) {
  	b, err := c.sendRequest(req)
  	if err != nil {
  		return nil, err
  	}
  	return proto.ReadCreateTopicsResp(bytes.NewReader(b))
  }
docs: // CreateTopic sends given createTopic request to kafka node and returns related
  // response.
  // Calling this method on closed connection will always return ErrClosed.