lib/clusters.js
function fetchProvisionedInfo (heroku, addon) {
  return heroku.request({
    host: host(addon),
    method: 'get',
    path: `/data/kafka/v0/clusters/${addon.id}`
  }).catch(err => {
    if (err.statusCode !== 404) throw err
    cli.exit(1, `${cli.color.addon(addon.name)} is not yet provisioned.\nRun ${cli.color.cmd('heroku kafka:wait')} to wait until the cluster is provisioned.`)
  })
}
function fetchProvisionedInfo (heroku, addon) {
  return heroku.request({
    host: host(addon),
    method: 'get',
    path: `/data/kafka/v0/clusters/${addon.id}`
  }).catch(err => {
    if (err.statusCode !== 404) throw err
    cli.exit(1, `${cli.color.addon(addon.name)} is not yet provisioned.\nRun ${cli.color.cmd('heroku kafka:wait')} to wait until the cluster is provisioned.`)
  })
}
function fetchProvisionedInfo ( heroku , addon ) { return heroku . request ( { host : host ( addon ) , method : 'get' , path : ` ${ addon . id } ` } ) . catch ( err => { if ( err . statusCode !== 404 ) throw err cli . exit ( 1 , ` ${ cli . color . addon ( addon . name ) } \n ${ cli . color . cmd ( 'heroku kafka:wait' ) } ` ) } ) }
Fetch kafka info about a provisioned cluster or exit with failure
Fetch kafka info about a provisioned cluster or exit with failure