DescribeTopicPartitions

Source: src/AWS/Kafka/DescribeTopicPartitions.ts

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

Reads per-partition detail (leader, replicas, ISR) for a topic through the MSK control plane. Pass NextToken from the previous page to paginate. Provide the implementation with Effect.provide(AWS.Kafka.DescribeTopicPartitionsHttp).

Managing Topics

const describeTopicPartitions = yield* Kafka.DescribeTopicPartitions(cluster);

const page = yield* describeTopicPartitions({ TopicName: "orders" });
// page.Partitions → [{ Partition: 0, Leader: …, Isr: […] }, …]