sarama

Documentation

Index

• func GetOffsets(client sarama.Client, topicPartitions map[string][]int32, time int64) (map[string]map[int32]int64, error)

Functions

func GetOffsets

func GetOffsets(client sarama.Client, topicPartitions map[string][]int32, time int64) (map[string]map[int32]int64, error)

GetOffsets queries the cluster to get the most recent available offset at the given time (in milliseconds) for the given topics and partition Time should be OffsetOldest for the earliest available offset, OffsetNewest for the offset of the message that will be produced next, or a time.

See sarama.Client.GetOffset for getting the offset of a single topic/partition combination