本文為您介紹如何配置阿里云E-MapReduce集群中的Kafka服務,包括修改相關配置以監聽公網接口以及設置對應的安全組規則,從而使得客戶端能夠在公網環境下順利訪問該集群上的Kafka服務。
新建集群時,開通公網服務
新建Dataflow集群時,打開Core節點組掛載公網的開關,則創建出來的Dataflow集群將自動開通Kafka服務公網訪問。
集群創建后,為安全組開通9093端口后,您便能通過公網IP的9093端口直接訪問Kafka服務。開通安全組詳情,請參見管理安全組。
開通已有集群的公網服務
Dataflow集群部署在VPC網絡環境,您可以通過掛載彈性公網IP或者高速通道兩種方式在外網環境訪問Kafka服務。
方式一:掛載彈性公網IP
進入基礎信息頁面。
在頂部菜單欄處,根據實際情況選擇地域和資源組。
在EMR on ECS頁面,單擊目標集群的集群ID。
在基礎信息頁面,單擊集群安全組后面的鏈接,為安全組開通9093端口,詳情請參見管理安全組。
為所有KafkaBroker組件的ECS實例掛載公網IP。
在節點管理頁面,選擇上方的
,同步公網IP信息到Dataflow集群。在E-MapReduce控制臺的Kafka服務的配置頁面,修改kafka.public-access.enable的參數值為true。
部署客戶端配置。
在Kafka服務的配置頁面,單擊部署客戶端配置。
在彈出的對話框中,輸入執行原因,單擊確定。
在確認對話框中,單擊確定。
重啟Kafka服務。
在Kafka服務的狀態頁面的組件列表區域,單擊KafkaBroker組件操作列的
。在彈出的對話框中,輸入執行原因,單擊確定。
在確認對話框中,單擊確定。
方式二:部署高速通道
部署高速通道打通內網和公網網絡,詳情請參見什么是高速通道。
訪問Kafka服務
訪問一個配置了公網IP地址的Kafka Broker服務時,URL格式通常為<Broker的公網IP地址>:9093
。
例如:如果某個Broker的公網IP地址為211.90.**.**,則Kafka服務的訪問地址是211.90.**.**:9093
。
相關文檔
如果您需要新建集群并快速使用EMR Kafka,詳情請參見快速開始使用EMR Kafka。