主题操作 - Amazon Managed Streaming for Apache Kafka
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅 中国的 Amazon Web Services 服务入门 (PDF)

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

主题操作

您可以使用 Amazon MSK APIs 管理您的 MSK 预配置集群中的主题,而无需设置和维护 Kafka 管理员客户端。有了这些 APIs,您可以定义或读取主题属性,例如复制因子和分区计数,以及保留和清理策略等配置设置。您可以使用熟悉的界面(包括 CL Amazon I、 Amazon SDKs和)以编程方式管理 Kafka 主题。 Amazon CloudFormation APIs 它们还集成到 Amazon MSK 控制台中,将所有主题操作集中到一个地方。现在,您只需点击几下即可使用引导式默认设置创建或更新主题,同时全面了解主题配置、分区级信息和指标。

重要

这些主题 API 响应反映的数据大约每分钟更新一次。要了解更改后的最新主题状态,请在查询前等待大约一分钟。

使用主题的要求 APIs

  • 您的集群必须是 MSK 预配置的集群。 APIs 这些不适用于 MSK 无服务器集群。

  • 您的集群必须运行 Apache Kafka 版本 3.6.0 或更高版本。有关支持的版本的更多信息,请参阅支持的 Apache Kafka 版本

  • 您的集群必须处于ACTIVE状态。有关集群状态的更多信息,请参阅了解预置 MSK 集群状态

  • 您必须拥有相应的 IAM 权限。有关更多信息,请参阅 用于主题操作的 IAM 权限 APIs

用于主题操作的 IAM 权限 APIs

要调用它们 APIs,您必须拥有相应的 IAM 权限。下表列出了每个 API 所需的权限。

主题操作所需的权限 APIs
API 所需权限 资源
ListTopics

kafka-cluster:Connect

kafka-cluster:DescribeTopic

集群 ARN,主题 ARN
DescribeTopic

kafka-cluster:Connect

kafka-cluster:DescribeTopic

kafka-cluster:DescribeTopicDynamicConfiguration

集群 ARN,主题 ARN
DescribeTopicPartitions

kafka-cluster:Connect

kafka-cluster:DescribeTopic

kafka-cluster:DescribeTopicDynamicConfiguration

集群 ARN,主题 ARN
CreateTopic

kafka-cluster:Connect

kafka-cluster:CreateTopic

集群 ARN,主题 ARN
DeleteTopic

kafka-cluster:Connect

kafka-cluster:DescribeTopic

kafka-cluster:DeleteTopic

集群 ARN,主题 ARN
UpdateTopic

kafka-cluster:Connect

kafka-cluster:DescribeTopic

kafka-cluster:AlterTopic

kafka-cluster:AlterTopicDynamicConfiguration

集群 ARN,主题 ARN
注意

对于kafka-cluster:Connect,请在您的 IAM 策略中指定集群 ARN。对于所有其他操作,请在您的 IAM 策略中指定主题 ARN。

注意

对于ListTopics,您可以使用通配符 (*) 来匹配集群上的所有主题。例如:arn:aws:kafka:us-east-1:123456789012:topic/my-cluster/abcd1234-abcd-dcba-4321-a1b2abcd9f9f-2/*

有关适用于 Amazon MSK 的 IAM 访问控制的更多信息,请参阅IAM 访问控制