abstract fun beginningOffsets(topicPartitions: MutableSet<TopicPartition>, handler: Handler<AsyncResult<MutableMap<TopicPartition, Long>>>): Unit
Get the first offset for the given partitions.
topicPartitions - the partitions to get the earliest offsets.
handler - handler called on operation completed. Returns the earliest available offsets for the given partitions
abstract fun beginningOffsets(topicPartition: TopicPartition, handler: Handler<AsyncResult<Long>>): Unit
Get the first offset for the given partitions.
topicPartition - the partition to get the earliest offset.
handler - handler called on operation completed. Returns the earliest available offset for the given partition