AWS托管Kafka的HTTP端点是通过Amazon MSK(Managed Streaming for Kafka)来提供的。为了获取HTTP端点,您需要使用AWS SDK(Software Development Kit)或AWS CLI(Command Line Interface)来调用Amazon MSK的API。
以下是使用AWS SDK for Python(即boto3)的示例代码:
import boto3
# 创建Amazon MSK客户端
client = boto3.client('kafka', region_name='us-west-2')
# 获取Kafka集群的HTTP端点
response = client.get_bootstrap_brokers(
ClusterArn='arn:aws:kafka:us-west-2:123456789012:cluster/my-kafka-cluster'
)
# 提取HTTP端点
http_endpoint = response['BootstrapBrokerStringTls']
print(f"Kafka HTTP端点: {http_endpoint}")
请确保替换region_name和ClusterArn的值为您自己的AWS区域和Amazon MSK集群ARN。
使用AWS CLI的示例命令如下:
aws kafka get-bootstrap-brokers --region us-west-2 --cluster-arn arn:aws:kafka:us-west-2:123456789012:cluster/my-kafka-cluster
请确保替换--region和--cluster-arn的值为您自己的AWS区域和Amazon MSK集群ARN。
通过以上代码示例,您可以获取到AWS托管Kafka的HTTP端点。
上一篇:AWS托管更新会覆盖本地文件