@@ -139,6 +139,21 @@ export class Kafka extends PolicyStatement {
139139 return this . to ( 'CreateReplicator' ) ;
140140 }
141141
142+ /**
143+ * Grants permission to create a Kafka topic in an MSK cluster
144+ *
145+ * Access Level: Write
146+ *
147+ * Dependent actions:
148+ * - kafka-cluster:Connect
149+ * - kafka-cluster:CreateTopic
150+ *
151+ * https://docs.aws.amazon.com/msk/1.0/apireference/clusters-clusterarn-topics.html
152+ */
153+ public toCreateTopic ( ) {
154+ return this . to ( 'CreateTopic' ) ;
155+ }
156+
142157 /**
143158 * Grants permission to create a MSK VPC connection
144159 *
@@ -215,6 +230,22 @@ export class Kafka extends PolicyStatement {
215230 return this . to ( 'DeleteReplicator' ) ;
216231 }
217232
233+ /**
234+ * Grants permission to delete a Kafka topic from an MSK cluster
235+ *
236+ * Access Level: Write
237+ *
238+ * Dependent actions:
239+ * - kafka-cluster:Connect
240+ * - kafka-cluster:DeleteTopic
241+ * - kafka-cluster:DescribeTopic
242+ *
243+ * https://docs.aws.amazon.com/msk/1.0/apireference/clusters-clusterarn-topics-topicname.html
244+ */
245+ public toDeleteTopic ( ) {
246+ return this . to ( 'DeleteTopic' ) ;
247+ }
248+
218249 /**
219250 * Grants permission to delete a MSK VPC connection
220251 *
@@ -745,6 +776,23 @@ export class Kafka extends PolicyStatement {
745776 return this . to ( 'UpdateStorage' ) ;
746777 }
747778
779+ /**
780+ * Grants permission to update the configuration of a Kafka topic in an MSK cluster
781+ *
782+ * Access Level: Write
783+ *
784+ * Dependent actions:
785+ * - kafka-cluster:AlterTopic
786+ * - kafka-cluster:AlterTopicDynamicConfiguration
787+ * - kafka-cluster:Connect
788+ * - kafka-cluster:DescribeTopic
789+ *
790+ * https://docs.aws.amazon.com/msk/1.0/apireference/clusters-clusterarn-topics-topicname.html
791+ */
792+ public toUpdateTopic ( ) {
793+ return this . to ( 'UpdateTopic' ) ;
794+ }
795+
748796 protected accessLevelList : AccessLevelList = {
749797 Write : [
750798 'BatchAssociateScramSecret' ,
@@ -753,11 +801,13 @@ export class Kafka extends PolicyStatement {
753801 'CreateClusterV2' ,
754802 'CreateConfiguration' ,
755803 'CreateReplicator' ,
804+ 'CreateTopic' ,
756805 'CreateVpcConnection' ,
757806 'DeleteCluster' ,
758807 'DeleteClusterPolicy' ,
759808 'DeleteConfiguration' ,
760809 'DeleteReplicator' ,
810+ 'DeleteTopic' ,
761811 'DeleteVpcConnection' ,
762812 'PutClusterPolicy' ,
763813 'RebootBroker' ,
@@ -773,7 +823,8 @@ export class Kafka extends PolicyStatement {
773823 'UpdateRebalancing' ,
774824 'UpdateReplicationInfo' ,
775825 'UpdateSecurity' ,
776- 'UpdateStorage'
826+ 'UpdateStorage' ,
827+ 'UpdateTopic'
777828 ] ,
778829 Read : [
779830 'DescribeCluster' ,
0 commit comments