AWS MSK Connector Rest API使用疑问：如何启用8083端口并更新配置

首先明确：AWS MSK Connector的REST API既不绑定在MSK集群的9094端口，也不是本地的8083端口——后者是本地自托管Kafka Connect的默认端口，完全不适用于AWS托管的MSK Connector服务。下面是两种可行的解决方案：

方法1：用AWS CLI直接更新容量（官方推荐） #

AWS MSK Connector是托管服务，官方优先推荐通过AWS CLI或SDK管理配置，无需直接调用Kafka Connect的REST API。更新容量的命令示例如下：

自动扩容配置 #

aws msk-connect update-connector \
  --connector-arn "arn:aws:kafka-connect:你的区域:账号ID:connector/你的连接器名称" \
  --capacity "{\"autoScaling\":{\"maxWorkerCount\":5,\"minWorkerCount\":2,\"scaleInPolicy\":{\"cpuUtilizationPercentage\":20},\"scaleOutPolicy\":{\"cpuUtilizationPercentage\":80}}}"

固定容量配置 #

aws msk-connect update-connector \
  --connector-arn "你的连接器ARN" \
  --capacity "{\"provisionedCapacity\":{\"workerCount\":3}}"

方法2：VPC内访问Kafka Connect原生REST API #

如果确实需要调用原生REST API，必须在MSK Connector所在的VPC内启动EC2实例，按以下步骤操作：

• 配置EC2安全组，允许访问MSK Connector安全组的8083端口
• 在AWS控制台的MSK Connect页面，找到你的连接器的REST API端点（格式类似https://<连接器ID>.kafka-connect.<区域>.amazonaws.com），这才是实际的API地址，而非localhost
• 通过EC2实例调用API更新容量，示例：

curl -X PUT https://<连接器REST端点>.kafka-connect.<区域>.amazonaws.com/connectors/你的连接器名称/config \
  -H "Content-Type: application/json" \
  -d '{"tasks.max":3}'

注意：EC2实例需要附加具备kafka-connect:*权限的IAM角色，或者对请求进行AWS SigV4签名认证。

关键误区澄清 #

• localhost:8083是本地自托管Kafka Connect的端口，和AWS托管MSK Connector无关
• MSK集群的9094是Kafka Broker的SSL端口，和Connector的REST API端口完全独立
• 托管MSK Connector的REST API默认启用，但仅允许VPC内部访问，若需外部访问需通过API Gateway或VPC端点转发

内容的提问来源于stack exchange，提问作者SatyaG