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

Package-level declarations

Inherited functions

fun Flow<ListClientVpcConnectionsResponse>.clientVpcConnections(): Flow<ClientVpcConnection>

This paginator transforms the flow returned by listClientVpcConnectionsPaginated to access the nested member ClientVpcConnection

clusterInfoList

fun Flow<ListClustersResponse>.clusterInfoList(): Flow<ClusterInfo>

This paginator transforms the flow returned by listClustersPaginated to access the nested member ClusterInfo

fun Flow<ListClustersV2Response>.clusterInfoList(): Flow<Cluster>

This paginator transforms the flow returned by listClustersV2Paginated to access the nested member Cluster

clusterOperationInfoList

fun Flow<ListClusterOperationsResponse>.clusterOperationInfoList(): Flow<ClusterOperationInfo>

This paginator transforms the flow returned by listClusterOperationsPaginated to access the nested member ClusterOperationInfo

fun Flow<ListClusterOperationsV2Response>.clusterOperationInfoList(): Flow<ClusterOperationV2Summary>

This paginator transforms the flow returned by listClusterOperationsV2Paginated to access the nested member ClusterOperationV2Summary

configurations

fun Flow<ListConfigurationsResponse>.configurations(): Flow<Configuration>

This paginator transforms the flow returned by listConfigurationsPaginated to access the nested member Configuration

describeTopicPartitionsPaginated

fun KafkaClient.describeTopicPartitionsPaginated(initialRequest: DescribeTopicPartitionsRequest): Flow<DescribeTopicPartitionsResponse>

fun KafkaClient.describeTopicPartitionsPaginated(block: DescribeTopicPartitionsRequest.Builder.() -> Unit): Flow<DescribeTopicPartitionsResponse>

Paginate over DescribeTopicPartitionsResponse results.

kafkaVersions

fun Flow<ListKafkaVersionsResponse>.kafkaVersions(): Flow<KafkaVersion>

This paginator transforms the flow returned by listKafkaVersionsPaginated to access the nested member KafkaVersion

listClientVpcConnectionsPaginated

fun KafkaClient.listClientVpcConnectionsPaginated(initialRequest: ListClientVpcConnectionsRequest): Flow<ListClientVpcConnectionsResponse>

fun KafkaClient.listClientVpcConnectionsPaginated(block: ListClientVpcConnectionsRequest.Builder.() -> Unit): Flow<ListClientVpcConnectionsResponse>

Paginate over ListClientVpcConnectionsResponse results.

listClusterOperationsPaginated

fun KafkaClient.listClusterOperationsPaginated(initialRequest: ListClusterOperationsRequest): Flow<ListClusterOperationsResponse>

fun KafkaClient.listClusterOperationsPaginated(block: ListClusterOperationsRequest.Builder.() -> Unit): Flow<ListClusterOperationsResponse>

Paginate over ListClusterOperationsResponse results.

listClusterOperationsV2Paginated

fun KafkaClient.listClusterOperationsV2Paginated(initialRequest: ListClusterOperationsV2Request): Flow<ListClusterOperationsV2Response>

fun KafkaClient.listClusterOperationsV2Paginated(block: ListClusterOperationsV2Request.Builder.() -> Unit): Flow<ListClusterOperationsV2Response>

Paginate over ListClusterOperationsV2Response results.

listClustersPaginated

fun KafkaClient.listClustersPaginated(initialRequest: ListClustersRequest = ListClustersRequest { }): Flow<ListClustersResponse>

fun KafkaClient.listClustersPaginated(block: ListClustersRequest.Builder.() -> Unit): Flow<ListClustersResponse>

Paginate over ListClustersResponse results.

listClustersV2Paginated

fun KafkaClient.listClustersV2Paginated(initialRequest: ListClustersV2Request = ListClustersV2Request { }): Flow<ListClustersV2Response>

fun KafkaClient.listClustersV2Paginated(block: ListClustersV2Request.Builder.() -> Unit): Flow<ListClustersV2Response>

Paginate over ListClustersV2Response results.

listConfigurationRevisionsPaginated

fun KafkaClient.listConfigurationRevisionsPaginated(initialRequest: ListConfigurationRevisionsRequest): Flow<ListConfigurationRevisionsResponse>

fun KafkaClient.listConfigurationRevisionsPaginated(block: ListConfigurationRevisionsRequest.Builder.() -> Unit): Flow<ListConfigurationRevisionsResponse>

Paginate over ListConfigurationRevisionsResponse results.

listConfigurationsPaginated

fun KafkaClient.listConfigurationsPaginated(initialRequest: ListConfigurationsRequest = ListConfigurationsRequest { }): Flow<ListConfigurationsResponse>

fun KafkaClient.listConfigurationsPaginated(block: ListConfigurationsRequest.Builder.() -> Unit): Flow<ListConfigurationsResponse>

Paginate over ListConfigurationsResponse results.

listKafkaVersionsPaginated

fun KafkaClient.listKafkaVersionsPaginated(initialRequest: ListKafkaVersionsRequest = ListKafkaVersionsRequest { }): Flow<ListKafkaVersionsResponse>

fun KafkaClient.listKafkaVersionsPaginated(block: ListKafkaVersionsRequest.Builder.() -> Unit): Flow<ListKafkaVersionsResponse>

Paginate over ListKafkaVersionsResponse results.

listNodesPaginated

fun KafkaClient.listNodesPaginated(initialRequest: ListNodesRequest): Flow<ListNodesResponse>

fun KafkaClient.listNodesPaginated(block: ListNodesRequest.Builder.() -> Unit): Flow<ListNodesResponse>

Paginate over ListNodesResponse results.

listReplicatorsPaginated

fun KafkaClient.listReplicatorsPaginated(initialRequest: ListReplicatorsRequest = ListReplicatorsRequest { }): Flow<ListReplicatorsResponse>

fun KafkaClient.listReplicatorsPaginated(block: ListReplicatorsRequest.Builder.() -> Unit): Flow<ListReplicatorsResponse>

Paginate over ListReplicatorsResponse results.

listScramSecretsPaginated

fun KafkaClient.listScramSecretsPaginated(initialRequest: ListScramSecretsRequest): Flow<ListScramSecretsResponse>

fun KafkaClient.listScramSecretsPaginated(block: ListScramSecretsRequest.Builder.() -> Unit): Flow<ListScramSecretsResponse>

Paginate over ListScramSecretsResponse results.

listTopicsPaginated

fun KafkaClient.listTopicsPaginated(initialRequest: ListTopicsRequest): Flow<ListTopicsResponse>

fun KafkaClient.listTopicsPaginated(block: ListTopicsRequest.Builder.() -> Unit): Flow<ListTopicsResponse>

Paginate over ListTopicsResponse results.

listVpcConnectionsPaginated

fun KafkaClient.listVpcConnectionsPaginated(initialRequest: ListVpcConnectionsRequest = ListVpcConnectionsRequest { }): Flow<ListVpcConnectionsResponse>

fun KafkaClient.listVpcConnectionsPaginated(block: ListVpcConnectionsRequest.Builder.() -> Unit): Flow<ListVpcConnectionsResponse>

Paginate over ListVpcConnectionsResponse results.

nodeInfoList

fun Flow<ListNodesResponse>.nodeInfoList(): Flow<NodeInfo>

This paginator transforms the flow returned by listNodesPaginated to access the nested member NodeInfo

partitions

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

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

replicators

fun Flow<ListReplicatorsResponse>.replicators(): Flow<ReplicatorSummary>

This paginator transforms the flow returned by listReplicatorsPaginated to access the nested member ReplicatorSummary

revisions

fun Flow<ListConfigurationRevisionsResponse>.revisions(): Flow<ConfigurationRevision>

This paginator transforms the flow returned by listConfigurationRevisionsPaginated to access the nested member ConfigurationRevision

secretArnList

fun Flow<ListScramSecretsResponse>.secretArnList(): Flow<String>

This paginator transforms the flow returned by listScramSecretsPaginated to access the nested member String

topics

fun Flow<ListTopicsResponse>.topics(): Flow<TopicInfo>

This paginator transforms the flow returned by listTopicsPaginated to access the nested member TopicInfo

vpcConnections

fun Flow<ListVpcConnectionsResponse>.vpcConnections(): Flow<VpcConnection>

This paginator transforms the flow returned by listVpcConnectionsPaginated to access the nested member VpcConnection