主題操作 - Amazon Managed Streaming for Apache Kafka

本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。

主題操作

您可以使用 Amazon MSK APIs 來管理 MSK 佈建叢集中的主題,而不需要設定和維護 Kafka 管理員用戶端。使用這些 APIs,您可以定義或讀取複寫係數和分割區計數等主題屬性,以及保留和清除政策等組態設定。您可以使用熟悉的界面以程式設計方式管理 Kafka 主題,包括 AWS CLI、SDK 和 AWS CloudFormation。 AWS SDKs 這些 APIs也會整合到 Amazon MSK 主控台,將所有主題操作集中到一處。您現在可以使用引導式預設值,只要按幾下滑鼠就能建立或更新主題,同時全面了解主題組態、分割區層級資訊和指標。

重要

這些主題 API 回應反映大約每分鐘更新的資料。對於進行變更後的最新主題狀態,請等待大約一分鐘再查詢。

使用主題 APIs的需求

  • 您的叢集必須是 MSK 佈建叢集。這些 APIs不適用於 MSK Serverless 叢集。

  • 您的叢集必須執行 Apache Kafka 3.6.0 版或更新版本。如需支援版本的詳細資訊,請參閱 支援的 Apache Kafka 版本

  • 您的叢集必須處於 ACTIVE 狀態。如需有關叢集狀態的詳細資訊,請參閱 了解 MSK 佈建叢集狀態

  • 您必須擁有適當的 IAM 許可。如需詳細資訊,請參閱主題操作 APIs IAM 許可

主題操作 APIs IAM 許可

若要呼叫這些 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 存取控制