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
Name Description
adminClient com.google.cloud.pubsublite.AdminClient
topicPath com.google.cloud.pubsublite.TopicPath

Methods

close()

public void close()

getPartitionCount()

public int getPartitionCount()
Returns
Type Description
int