主题操作 - Amazon Managed Streaming for Apache Kafka

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

主题操作

您可以使用 Amazon MSK APIs 管理您的 MSK 预配置集群中的主题,而无需设置和维护 Kafka 管理员客户端。有了这些 APIs,您可以定义或读取主题属性,例如复制因子和分区计数,以及保留和清理策略等配置设置。您可以使用熟悉的界面(包括 CL AWS I、 AWS SDKs和)以编程方式管理 Kafka 主题。 AWS 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 访问控制