Skip to content

UpdateTopic

Source: src/AWS/Kafka/UpdateTopic.ts

Runtime binding for the UpdateTopic operation (IAM action kafka:UpdateTopic), scoped to one ServerlessCluster.

Updates a topic’s configuration or increases its partition count through the MSK control plane. Provide the implementation with Effect.provide(AWS.Kafka.UpdateTopicHttp).

const updateTopic = yield* Kafka.UpdateTopic(cluster);
yield* updateTopic({ TopicName: "orders", PartitionCount: 6 });