Class CachedPartitionCountReader (0.4.5) 

public class CachedPartitionCountReader implements PartitionCountReader

Inheritance

java.lang.Object > CachedPartitionCountReader

Constructors

CachedPartitionCountReader(AdminClient adminClient, TopicPath topicPath)

public CachedPartitionCountReader(AdminClient adminClient, TopicPath topicPath)
Parameters
NameDescription
adminClientcom.google.cloud.pubsublite.AdminClient
topicPathcom.google.cloud.pubsublite.TopicPath

Methods

close()

public void close()

getPartitionCount()

public int getPartitionCount()
Returns
TypeDescription
int