无法通过AWS CLI列出及描述MSK Topic配置的问题求助
关于AWS CLI操作MSK Topic配置的问题
首先明确:AWS CLI的kafka describe-configuration命令不能用来查看单个Topic的配置——这个命令是用来管理MSK集群的「配置方案(Configuration)」的,也就是集群层面的broker配置模板,和Topic无关,所以你用Topic的ARN去调用肯定会报错。
正确查看MSK Topic的方法
MSK是托管版Kafka,要查看Topic列表和配置,得用Kafka原生的客户端工具,步骤如下:
- 列出集群内所有Topic
使用kafka-topics.sh工具,命令示例:kafka-topics.sh --bootstrap-server <你的MSK集群引导服务器地址> --list --command-config client.properties - 查看单个Topic的配置
使用kafka-configs.sh工具,命令示例:kafka-configs.sh --bootstrap-server <你的MSK集群引导服务器地址> --describe --topic <目标Topic名称> --command-config client.properties
关于认证配置
你需要提前准备client.properties文件,根据集群的IAM认证方式配置:
security.protocol=SASL_SSL sasl.mechanism=AWS_MSK_IAM sasl.jaas.config=software.amazon.msk.auth.iam.IAMLoginModule required; sasl.client.callback.handler.class=software.amazon.msk.auth.iam.IAMClientCallbackHandler
如果集群用的是其他认证方式(比如SASL/SCRAM),对应调整配置即可。
为什么你的命令报错
你用的describe-configuration命令需要传入MSK配置方案的ARN,格式是:arn:aws:kafka:region:account-id:configuration/<配置名称>/<配置ID>
而不是Topic的ARN,参数不匹配自然会触发BadRequestException。
内容的提问来源于stack exchange,提问作者l4t3b0
相关产品推荐
相关产品推荐

