kafka/aws.sdk.kotlin.services.kafka.paginators/partitions

partitions

@JvmName(name = "describeTopicPartitionsResponseTopicPartitionInfo")

fun Flow<DescribeTopicPartitionsResponse>.partitions(): Flow<TopicPartitionInfo>

This paginator transforms the flow returned by describeTopicPartitionsPaginated to access the nested member TopicPartitionInfo

Return

A kotlinx.coroutines.flow.Flow that can collect TopicPartitionInfo