Function NewPartitionOffsetClient

pkg/ingest/partition_offset_client.go:29–34

(client *kgo.Client, topic string)

}

func NewPartitionOffsetClient(client *kgo.Client, topic string) *PartitionOffsetClient {
	return &PartitionOffsetClient{
		client: client,
		topic:  topic,
	}
}

// FetchPartitionsLastProducedOffsets fetches and returns the last produced offsets for all input partitions.  The returned offsets for each partition
// are guaranteed to be always updated (no stale or cached offsets returned).