Package com.google.cloud.pubsublite.spark.internal (1.0.0)

Cached Publishers to reuse publisher of same settings in the same task.

Singleton class that caches subscriber service clients to be re-used by the same task.

Rate limited HeadOffsetReader, utilizing a LoadingCache that refreshes all partitions head offsets for the topic at most once per minute.

A MultiPartitionCommitter that lazily adjusts for partition changes when MultiPartitionCommitter#commit(PslSourceOffset) is called.