import type * as kafka from "@distilled.cloud/aws/kafka";
import type * as Effect from "effect/Effect";
import * as Binding from "../../Binding.ts";
import type { ServerlessCluster } from "./ServerlessCluster.ts";
/**
 * Runtime binding for the `CreateTopic` operation (IAM action
 * `kafka:CreateTopic`), scoped to one {@link 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
 * **Example:** Create a Topic
 * ```typescript
 * const createTopic = yield* Kafka.CreateTopic(cluster);
 *
 * const topic = yield* createTopic({
 *   TopicName: "orders",
 *   PartitionCount: 3,
 * });
 * // topic.TopicArn, topic.Status → "CREATING" | "ACTIVE"
 * ```
 *
 * @binding
 */
export interface CreateTopic extends Binding.Service<CreateTopic, "AWS.Kafka.CreateTopic", (cluster: ServerlessCluster) => Effect.Effect<(request: Omit<kafka.CreateTopicRequest, "ClusterArn">) => Effect.Effect<kafka.CreateTopicResponse, kafka.CreateTopicError>>> {
}
export declare const CreateTopic: CreateTopic;
//# sourceMappingURL=CreateTopic.d.ts.map