fetchLatest method

Future<List<TopicOffset>> fetchLatest(
  1. Map<String, Set<int>> topicPartitions
)

Returns latest offsets (that is the offset of next incoming message) for specified topics and partitions.

These offsets are also called 'highWatermark' offsets in Kafka docs.

Implementation

Future<List<TopicOffset>> fetchLatest(Map<String, Set<int>> topicPartitions) {
  return _fetch(topicPartitions, -1);
}