# HBase Master Wait

    module.exports =  header: 'Kafka Broker Wait', handler: ({options}) ->

## Broker Port

      @connection.wait
        header: 'PLAINTEXT'
        if: !!options['PLAINTEXT']
        servers: options['PLAINTEXT']
        
      @connection.wait
        header: 'SSL'
        if: !!options['SSL']
        servers: options['SSL']

      @connection.wait
        header: 'SASL_PLAINTEXT'
        if: !!options['SASL_PLAINTEXT']
        servers: options['SASL_PLAINTEXT']
              
      @connection.wait
        header: 'SASL_SSL'
        if: !!options['SASL_SSL']
        servers: options['SASL_SSL']