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

前提条件

网络连接测试

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

发送消息测试

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

    示例： java -jar KafkaChecker.jar send -s alikafka-pre-cn-zv**********-1-vpc.alikafka.aliyuncs.com: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 接入点域名:9093 --topic Topic名称

      示例：java -jar KafkaChecker.jar send -sm PLAIN -ss true -u test -psw test**** -s alikafka-pre-cn-zv**********-1.alikafka.aliyuncs.com:9093 --topic test

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

      示例：java -jar KafkaChecker.jar send -sm SCRAM-SHA-256 -ss true -u test -psw test**** -s alikafka-pre-cn-zv**********-1.alikafka.aliyuncs.com: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 接入点域名:9094 --topic Topic名称

      示例：java -jar KafkaChecker.jar send -sm PLAIN -sp true -u test -psw test**** -s alikafka-pre-cn-zv**********-1-vpc.alikafka.aliyuncs.com:9094 --topic test

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

      示例：java -jar KafkaChecker.jar send -sm SCRAM-SHA-256 -sp true -u test -psw test**** -s alikafka-pre-cn-zv**********-1-vpc.alikafka.aliyuncs.com:9094 --topic test

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

消费消息测试

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

    示例：java -jar KafkaChecker.jar pull -s alikafka-pre-cn-zv**********-1-vpc.alikafka.aliyuncs.com: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 接入点域名: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 alikafka-pre-cn-zv**********-1.alikafka.aliyuncs.com: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 接入点域名: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 alikafka-pre-cn-zv**********-1.alikafka.aliyuncs.com: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 接入点域名: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 alikafka-pre-cn-zv**********-1-vpc.alikafka.aliyuncs.com: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 接入点域名: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 alikafka-pre-cn-zv**********-1-vpc.alikafka.aliyuncs.com:9094 --topic test --group test --partition 0 --offset 0 --count 10

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

Demo验证

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