Kafka Broker Check

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

Assert

  @connection.assert
    header: 'PLAINTEXT'
    if: !!options.wait['PLAINTEXT']
    servers: options.wait['PLAINTEXT']?.filter (server) -> server.host is options.fqdn
          
  @connection.assert
    header: 'SSL'
    if: !!options.wait['SSL']
    servers: options.wait['SSL']?.filter (server) -> server.host is options.fqdn
  
  @connection.assert
    header: 'SASL_PLAINTEXT'
    if: !!options.wait['SASL_PLAINTEXT']
    servers: options.wait['SASL_PLAINTEXT']?.filter (server) -> server.host is options.fqdn
          
  @connection.assert
    header: 'SASL_SSL'
    if: !!options.wait['SASL_SSL']
    servers: options.wait['SASL_SSL']?.filter (server) -> server.host is options.fqdn

Check TCP

Make sure the broker is listening. The default port is "9092".

  # @call header: 'Check TCP', ->
  #   for protocol in kafka.broker.protocols
  #     @system.execute
  #       cmd: "echo > /dev/tcp/#{@config.host}/#{kafka.broker.ports[protocol]}"