当实例运行出现异常时,您可以对实例的健康状态进行自检。本文介绍自检的具体方法。

前提条件

网络连接测试

  1. 获取接入点。
    1. 登录消息队列Kafka版控制台
    2. 概览页面的资源分布区域,选择地域。
    3. 实例列表页面,单击目标实例名称。
    4. 实例详情页面的接入点信息区域,获取实例的接入点。
      endpoint
      说明 不同接入点的差异,请参见接入点对比
  2. 在自检工具所在路径,运行系统终端执行器,执行java -jar KafkaChecker.jar telnet -s 接入点 命令,测试是否可以连接消息队列Kafka版
    示例:客户端通过专有网络VPC默认接入点接入消息队列Kafka版,执行java -jar KafkaChecker.jar telnet -s 192.168.XX.XX:9092,192.168.XX.XX:9092,192.168.XX.XX:9092
    提示如下类似信息,说明网络连接正常。VPC
    如果提示下图所示信息,说明未配置访问消息队列Kafka版的白名单,具体操作,请参见配置白名单WhiteList

发送消息测试

说明 发送消息将会产生真实的测试数据,请您创建Topic专门用于自检测试,避免影响正常业务数据。
根据网络接入方式,执行命令,发送消息。
  • 通过专有网络VPC默认接入点9092端口接入: java -jar KafkaChecker.jar send -s 接入点IP地址:9092 --topic Topic名称

    示例: java -jar KafkaChecker.jar send -s 192.168.XX.XX:9092 --topic test

  • 通过公网SSL接入点9093端口接入,SASL支持PLAIN机制或SCRAM-SHA-256机制校验身份,请您根据实际使用的身份校验机制执行对应的发送消息命令:
    说明 公网环境,实例的默认SASL用户使用PLIAN机制进行身份校验。创建SASL用户进行更细致的权限控制,您可以配置身份校验机制为PLAIN或SCRAM-SHA-256。具体操作,请参见SASL用户授权。请您根据实际使用的身份校验机制执行对应的发送消息命令。
    • PLAIN机制:java -jar KafkaChecker.jar send -sm PLAIN -ss true -u username -psw password -s 接入点IP地址:9093 --topic Topic名称

      示例:java -jar KafkaChecker.jar send -sm PLAIN -ss true -u test -psw test**** -s 192.51.XX.XX:9093 --topic test

    • SCRAM-SHA-256机制:java -jar KafkaChecker.jar send -sm SCRAM-SHA-256 -ss true -u username -psw password -s 接入点IP地址:9093 --topic Topic名称

      示例:java -jar KafkaChecker.jar send -sm SCRAM-SHA-256 -ss true -u test -psw test**** -s 192.51.XX.XX:9093 --topic test

  • 通过专有网络VPC SASL接入点9094端口接入,SASL支持PLAIN机制或SCRAM-SHA-256机制校验身份,请您根据实际使用的身份校验机制执行对应的发送消息命令:
    • PLAIN机制:java -jar KafkaChecker.jar send -sm PLAIN -sp true -u username -psw password -s 接入点IP地址:9094 --topic Topic名称

      示例:java -jar KafkaChecker.jar send -sm PLAIN -sp true -u test -psw test**** -s 192.168.XX.XX:9094 --topic test

    • SCRAM-SHA-256机制:java -jar KafkaChecker.jar send -sm SCRAM-SHA-256 -sp true -u username -psw password -s 接入点IP地址:9094 --topic Topic名称

      示例:java -jar KafkaChecker.jar send -sm SCRAM-SHA-256 -sp true -u test -psw test**** -s 192.168.XX.XX:9094 --topic test

提示如下类似信息,说明消息发送成功。result

消费消息测试

根据网络接入方式,执行命令,消费消息。
  • 通过专有网络VPC默认接入点9092端口接入:java -jar KafkaChecker.jar pull -s 接入点IP地址:9092 --topic Topic名称 --group Group名称 --partition 0 --offset 0 --count 10

    示例:java -jar KafkaChecker.jar pull -s 192.168.XX.XX:9092 --topic test --group test --partition 0 --offset 0 --count 10

  • 通过公网SSL接入点9093端口接入,SASL支持PLAIN机制或SCRAM-SHA-256机制校验身份,请您根据实际使用的身份校验机制执行对应的消费消息命令:
    说明 公网环境,实例的默认SASL用户使用PLIAN机制进行身份校验。创建SASL用户进行更细致的权限控制,您可以配置身份校验机制为PLAIN或SCRAM-SHA-256。具体操作,请参见SASL用户授权。请您根据实际使用的身份校验机制执行对应的消费消息命令。
    • PLAIN机制: java -jar KafkaChecker.jar pull -sm PLAIN -ss true -u username -psw password -s 接入点IP地址:9093 --topic Topic名称 --group Group名称 --partition 0 --offset 0 --count 10

      示例: java -jar KafkaChecker.jar pull -sm PLAIN -ss true -u test -psw test**** -s 192.51.XX.XX:9093 --topic test --group test --partition 0 --offset 0 --count 10

    • SCRAM-SHA-256机制: java -jar KafkaChecker.jar pull -sm SCRAM-SHA-256 -ss true -u username -psw password -s 接入点IP地址:9093 --topic Topic名称 --group Group名称 --partition 0 --offset 0 --count 10

      示例: java -jar KafkaChecker.jar pull -sm SCRAM-SHA-256 -ss true -u test -psw test**** -s 192.51.XX.XX:9093 --topic test --group test --partition 0 --offset 0 --count 10

  • 通过专有网络VPC SASL接入点9094端口接入,SASL支持PLAIN机制或SCRAM-SHA-256机制校验身份,请您根据实际使用的身份校验机制执行对应的消费消息命令:
    • PLAIN机制: java -jar KafkaChecker.jar pull -sm PLAIN -sp true -u username -psw password -s 接入点IP地址:9094 --topic Topic名称 --group Group名称 --partition 0 --offset 0 --count 10

      示例: java -jar KafkaChecker.jar pull -sm PLAIN -sp true -u test -psw test**** -s 192.168.XX.XX:9094 --topic test --group test --partition 0 --offset 0 --count 10

    • SCRAM-SHA-256机制: java -jar KafkaChecker.jar pull -sm SCRAM-SHA-256 -sp true -u username -psw password -s 接入点IP地址:9094 --topic Topic名称 --group Group名称 --partition 0 --offset 0 --count 10

      示例: java -jar KafkaChecker.jar pull -sm SCRAM-SHA-256 -sp true -u test -psw test**** -s 192.168.XX.XX:9094 --topic test --group test --partition 0 --offset 0 --count 10

提示如下类似信息,说明消费成功。consumer

Demo验证

如果以上步骤测试都正常,请使用Demo进行发送消息和消费消息测试,以排除您的客户端代码存在问题。请您根据需要下载相应的开发语言代码包,具体信息,请参见SDK概述