Managed Streaming for Kafka

2026/02/10 - Managed Streaming for Kafka - 3 new api methods

Changes  Amazon MSK adds three new APIs, CreateTopic, UpdateTopic, and DeleteTopic for managing Kafka topics in your MSK clusters.

DeleteTopic (new) Link ¶

Deletes a topic in the specified MSK cluster.

See also: AWS API Documentation

Request Syntax

client.delete_topic(
    ClusterArn='string',
    TopicName='string'
)
type ClusterArn:

string

param ClusterArn:

[REQUIRED]

The Amazon Resource Name (ARN) that uniquely identifies the cluster.

type TopicName:

string

param TopicName:

[REQUIRED]

The name of the topic to delete.

rtype:

dict

returns:

Response Syntax

{
    'TopicArn': 'string',
    'TopicName': 'string',
    'Status': 'CREATING'|'UPDATING'|'DELETING'|'ACTIVE'
}

Response Structure

  • (dict) --

    200 response

    • TopicArn (string) --

      The Amazon Resource Name (ARN) of the topic.

    • TopicName (string) --

      The name of the topic that was deleted.

    • Status (string) --

      The status of the topic deletion.

CreateTopic (new) Link ¶

Creates a topic in the specified MSK cluster.

See also: AWS API Documentation

Request Syntax

client.create_topic(
    ClusterArn='string',
    TopicName='string',
    PartitionCount=123,
    ReplicationFactor=123,
    Configs='string'
)
type ClusterArn:

string

param ClusterArn:

[REQUIRED]

The Amazon Resource Name (ARN) that uniquely identifies the cluster.

type TopicName:

string

param TopicName:

[REQUIRED]

The name of the topic to create.

type PartitionCount:

integer

param PartitionCount:

[REQUIRED]

The number of partitions for the topic.

type ReplicationFactor:

integer

param ReplicationFactor:

[REQUIRED]

The replication factor for the topic.

type Configs:

string

param Configs:

Topic configurations encoded as a Base64 string.

rtype:

dict

returns:

Response Syntax

{
    'TopicArn': 'string',
    'TopicName': 'string',
    'Status': 'CREATING'|'UPDATING'|'DELETING'|'ACTIVE'
}

Response Structure

  • (dict) --

    200 response

    • TopicArn (string) --

      The Amazon Resource Name (ARN) of the topic.

    • TopicName (string) --

      The name of the topic that was created.

    • Status (string) --

      The status of the topic creation.

UpdateTopic (new) Link ¶

Updates the configuration of the specified topic.

See also: AWS API Documentation

Request Syntax

client.update_topic(
    ClusterArn='string',
    TopicName='string',
    Configs='string',
    PartitionCount=123
)
type ClusterArn:

string

param ClusterArn:

[REQUIRED]

The Amazon Resource Name (ARN) that uniquely identifies the cluster.

type TopicName:

string

param TopicName:

[REQUIRED]

The name of the topic to update configuration for.

type Configs:

string

param Configs:

The new topic configurations encoded as a Base64 string.

type PartitionCount:

integer

param PartitionCount:

The new total number of partitions for the topic.

rtype:

dict

returns:

Response Syntax

{
    'TopicArn': 'string',
    'TopicName': 'string',
    'Status': 'CREATING'|'UPDATING'|'DELETING'|'ACTIVE'
}

Response Structure

  • (dict) --

    200 response

    • TopicArn (string) --

      The Amazon Resource Name (ARN) of the topic.

    • TopicName (string) --

      The name of the topic whose configuration was updated.

    • Status (string) --

      The status of the topic update.