CreateTopic

Source: src/AWS/Kafka/CreateTopic.ts

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

Creates a Kafka topic on the bound cluster through the MSK control plane — no Kafka admin client or VPC connectivity required. Provide the implementation with Effect.provide(AWS.Kafka.CreateTopicHttp).

Managing Topics

const createTopic = yield* Kafka.CreateTopic(cluster);

const topic = yield* createTopic({
  TopicName: "orders",
  PartitionCount: 3,
});
// topic.TopicArn, topic.Status → "CREATING" | "ACTIVE"