新建集群時，開通公網服務

新建Dataflow集群時，打開Core節點組掛載公網的開關，則創建出來的Dataflow集群將自動開通Kafka服務公網訪問。

集群創建后，為安全組開通9093端口后，您便能通過公網IP的9093端口直接訪問Kafka服務。開通安全組詳情，請參見管理安全組。

開通已有集群的公網服務

Dataflow集群部署在VPC網絡環境，您可以通過掛載彈性公網IP或者高速通道兩種方式在外網環境訪問Kafka服務。

方式一：掛載彈性公網IP

1. 進入基礎信息頁面。

   1. 登錄E-MapReduce控制臺。

   2. 在頂部菜單欄處，根據實際情況選擇地域和資源組。

   3. 在EMR on ECS頁面，單擊目標集群的集群ID。

2. 在基礎信息頁面，單擊集群安全組后面的鏈接，為安全組開通9093端口，詳情請參見管理安全組。

3. 為所有KafkaBroker組件的ECS實例掛載公網IP。

   1. 單擊節點管理頁簽。

   2. 在節點管理頁面，單擊節點的ID。

   3. 在ECS控制臺，為當前ECS實例掛載公網，詳情請參見綁定EIP。

   4. 重復步驟b~步驟c，為Kafka服務KafkaBroker組件的所有ECS實例掛載公網IP。

4. 在節點管理頁面，選擇上方的全部操作 > 同步主機信息，同步公網IP信息到Dataflow集群。

5. 在E-MapReduce控制臺的Kafka服務的配置頁面，修改kafka.public-access.enable的參數值為true。

6. 部署客戶端配置。

   1. 在Kafka服務的配置頁面，單擊部署客戶端配置。

   2. 在彈出的對話框中，輸入執行原因，單擊確定。

   3. 在確認對話框中，單擊確定。

7. 重啟Kafka服務。

   1. 在Kafka服務的狀態頁面的組件列表區域，單擊KafkaBroker組件操作列的重啟。

   2. 在彈出的對話框中，輸入執行原因，單擊確定。

   3. 在確認對話框中，單擊確定。

方式二：部署高速通道

部署高速通道打通內網和公網網絡，詳情請參見什么是高速通道。

訪問Kafka服務

訪問一個配置了公網IP地址的Kafka Broker服務時，URL格式通常為<Broker的公網IP地址>:9093。

例如：如果某個Broker的公網IP地址為211.90.**.**，則Kafka服務的訪問地址是211.90.**.**:9093。

相關文檔

如果您需要新建集群并快速使用EMR Kafka，詳情請參見快速開始使用EMR Kafka。