Kafka通过AWS私有连接进行宣传的侦听器

1. 首先，您需要启用VPC端点以使Kafka实例可以通过私有连接进行访问。以下是使用AWS CLI启用VPC端点的示例命令：

aws ec2 create-vpc-endpoint --vpc-id VPC_ID --service-name com.amazonaws.REGION_NAME.kafka --subnet-ids SUBNET_ID --security-group-ids SECURITY_GROUP_ID

其中VPC_ID是您的VPC ID，REGION_NAME是您的AWS区域，SUBNET_ID是您的子网ID，SECURITY_GROUP_ID是您的安全组ID。

2. 接下来，您需要配置Kafka以使用私有连接侦听器。以下是在Kafka配置中启用私有连接侦听器的示例：

listeners= PLAINTEXT://AWS_PRIVATELINK_DNS:9094 listener.security.protocol.map=PLAINTEXT:PLAINTEXT,INTERNAL:PLAINTEXT advertised.listeners= INTERNAL://kafka-INTERNAL.kafka.svc.cluster.local:9094

其中AWS_PRIVATELINK_DNS是VPC端点的DNS名称，"kafka-INTERNAL.kafka.svc.cluster.local" 是Kafka实例的内部主机名。

3. 最后，您需要更新访问控制策略以允许访问VPC端点。以下是一个示例IAM策略：

{ "Version": "2012-10-17", "Statement": [ { "Effect": "Allow", "Action": [ "ec2:DescribeVpcEndpoints" ], "Resource": "*" }, { "Effect": "Allow", "Action": [ "dynamodb:GetItem", "dynamodb:PutItem", "dynamodb:Query", "dynamodb:UpdateItem", "dynamodb:DeleteItem" ], "Resource": "arn:aws:dynamodb:REGION:ACCOUNT_ID:table/TABLE_NAME", "Condition": { "StringEquals": { "dynamodb:Endpoint": "VPC_ENDPOINT_DNS" } } } ] }

其中REGION、ACCOUNT_ID、TABLE_NAME