日本熟妇hd丰满老熟妇,中文字幕一区二区三区在线不卡 ,亚洲成片在线观看,免费女同在线一区二区

AI 助理
備案控制臺
文檔
輸入文檔關(guān)鍵字查找
首頁 云消息隊列 Kafka 版 云消息隊列 Kafka 版 快速入門 實例運行健康自檢指南

實例運行健康自檢指南

更新時間：
產(chǎn)品詳情
我的收藏

當(dāng)客戶端使用SDK無法收發(fā)消息或無法連接實例時，您可以使用Kafka的自檢工具對實例的健康狀態(tài)進行自檢，檢查網(wǎng)絡(luò)是否連通、實例狀態(tài)是否異常。若實例無異常，請檢查網(wǎng)絡(luò)是否連通、實例狀態(tài)是否異常、客戶端代碼配置是否正確以排除您的客戶端代碼存在問題。

前提條件

網(wǎng)絡(luò)連接測試

  1. 獲取接入點。

    1. 登錄云消息隊列 Kafka 版控制臺。

    2. 在概覽頁面的資源分布區(qū)域，選擇地域。

    3. 在實例列表頁面，單擊目標(biāo)實例名稱。

    4. 在實例詳情頁面的接入點信息區(qū)域，獲取實例的接入點。

      endpoint

      說明

      不同接入點的差異，請參見接入點對比。

  2. 測試接入點能否telnet通（以Linux操作系統(tǒng)為例）。

    1. 登錄Linux系統(tǒng)，進入自檢工具KafkaChecker.jar所在路徑。

      cd /usr/opt/kafka-checker

      請將/usr/opt/kafka-checker替換為本地路徑。

    2. 執(zhí)行以下命令，測試是否可以連接云消息隊列 Kafka 版。

      java -jar KafkaChecker.jar telnet -s 接入點

      例如：客戶端通過專有網(wǎng)絡(luò)VPC默認接入點接入云消息隊列 Kafka 版，則執(zhí)行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。

      說明

      使用專有網(wǎng)絡(luò)VPC連接點接入時，您的設(shè)備需要與實例處于同一VPC下。

      提示如下類似信息，說明網(wǎng)絡(luò)連接正常。VPC

      如果提示下圖所示信息，說明未配置訪問云消息隊列 Kafka 版的白名單，具體操作，請參見配置白名單。WhiteList

發(fā)送消息測試

說明

發(fā)送消息將會產(chǎn)生真實的測試數(shù)據(jù)，請您創(chuàng)建Topic專門用于自檢測試，避免影響正常業(yè)務(wù)數(shù)據(jù)。

根據(jù)網(wǎng)絡(luò)接入方式選擇對應(yīng)的命令，發(fā)送消息。

  • 通過專有網(wǎng)絡(luò)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

  • 通過公網(wǎng)SSL接入點9093端口接入，SASL支持PLAIN機制或SCRAM-SHA-256機制校驗身份，請您根據(jù)實際使用的身份校驗機制執(zhí)行對應(yīng)的發(fā)送消息命令：

    說明

    • 公網(wǎng)環(huán)境，實例的默認SASL用戶使用PLAIN機制進行身份校驗。

    • 創(chuàng)建SASL用戶可進行更細致的權(quán)限控制，您可以配置身份校驗機制為PLAIN或SCRAM-SHA-256。具體操作，請參見SASL用戶授權(quán)。請您根據(jù)實際使用的身份校驗機制執(zhí)行對應(yīng)的發(fā)送消息命令。

    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

  • 通過專有網(wǎng)絡(luò)VPC SASL接入點9094端口接入，SASL支持PLAIN機制或SCRAM-SHA-256機制校驗身份，請您根據(jù)實際使用的身份校驗機制執(zhí)行對應(yīng)的發(fā)送消息命令：

    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

提示如下類似信息，說明消息發(fā)送成功。result

消費消息測試

根據(jù)網(wǎng)絡(luò)接入方式選擇對應(yīng)的命令，消費消息。

  • 通過專有網(wǎng)絡(luò)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

  • 通過公網(wǎng)SSL接入點9093端口接入，SASL支持PLAIN機制或SCRAM-SHA-256機制校驗身份，請您根據(jù)實際使用的身份校驗機制執(zhí)行對應(yīng)的消費消息命令：

    說明

    • 公網(wǎng)環(huán)境，實例的默認SASL用戶使用PLAIN機制進行身份校驗。

    • 創(chuàng)建SASL用戶可進行更細致的權(quán)限控制，您可以配置身份校驗機制為PLAIN或SCRAM-SHA-256。具體操作，請參見SASL用戶授權(quán)。請您根據(jù)實際使用的身份校驗機制執(zhí)行對應(yīng)的消費消息命令。

    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

  • 通過專有網(wǎng)絡(luò)VPC SASL接入點9094端口接入，SASL支持PLAIN機制或SCRAM-SHA-256機制校驗身份，請您根據(jù)實際使用的身份校驗機制執(zhí)行對應(yīng)的消費消息命令：

    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

相關(guān)文檔

相關(guān)的SDK代碼包，請參見SDK概述。