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

在概覽頁面的資源分布區域，選擇地域。

在實例列表頁面，單擊目標實例名稱。

在實例詳情頁面的接入點信息頁簽，獲取實例的VPC環境接入點。

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

在概覽頁面的資源分布區域，選擇地域。

在實例列表頁面，單擊目標實例名稱。

在左側導航欄，單擊Topic 管理。

在Topic 管理頁面，單擊創建 Topic。

在創建 Topic面板，設置Topic屬性，然后單擊確定。

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

在概覽頁面的資源分布區域，選擇地域。

在實例列表頁面，單擊目標實例名稱。

在左側導航欄，單擊Topic 管理。

在Topic 管理頁面，單擊目標Topic名稱進入Topic 詳情頁面，然后單擊體驗發送消息。

在快速體驗消息收發面板，發送測試消息。

• 發送方式選擇控制臺。

  1. 在消息 Key文本框中輸入消息的Key值，例如demo。

  2. 在消息內容文本框輸入測試的消息內容，例如 {"key": "test"}。

  3. 設置發送到指定分區，選擇是否指定分區。

     • 單擊是，在分區 ID文本框中輸入分區的ID，例如0。如果您需查詢分區的ID，請參見查看分區狀態。

     • 單擊否，不指定分區。

  4. 根據界面提示信息，通過SDK訂閱消息，或者執行Docker命令訂閱消息。

• 發送方式選擇Docker，運行Docker容器。

  1. 執行運行 Docker 容器生產示例消息區域的Docker命令，發送消息。

  2. 執行發送后如何消費消息？區域的Docker命令，訂閱消息。

• 發送方式選擇SDK，根據您的業務需求，選擇需要的語言或者框架的SDK以及接入方式，通過SDK體驗消息收發。

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

在概覽頁面的資源分布區域，選擇地域。

在實例列表頁面，單擊目標實例名稱。

在左側導航欄，單擊Group 管理。

在Group 管理頁面，單擊創建 Group。

在創建 Group面板的Group ID文本框輸入Group的名稱，在描述文本框簡要描述Group，并給Group添加標簽，單擊確定。

登錄Kibana控制臺。

在Kibana控制臺的左側導航欄，單擊Dev Tools。

執行以下命令創建索引。

PUT /elastic_test
{}

登錄阿里云Elasticsearch控制臺的Logstash實例頁面。

在頂部菜單欄，選擇地域。

在Logstash實例頁面，單擊創建的實例。

在左側導航欄，單擊管道管理。

在管道列表區域，單擊創建管道。

在Config配置中，輸入配置。

input {
    kafka {
    bootstrap_servers => ["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"]
    group_id => "elastic_group"
    topics => ["elastic_test"]
    consumer_threads => 12
    decorate_events => true
    }
}
output {
    elasticsearch {
    hosts => ["http://es-cn-o40xxxxxxxxxxxxwm.elasticsearch.aliyuncs.com:9200"]
    index => "elastic_test"
    password => "XXX"
    user => "elastic"
    }
}

在管道參數配置中，輸入配置信息，然后單擊保存并部署。

在提示對話框，單擊確認。

登錄Kibana控制臺。

在Kibana控制臺的左側導航欄，單擊Dev Tools圖標。

執行以下命令搜索數據。

GET /elastic_test/_search
{}