Function makeCommits

commit.go:24–32

makeCommits generates a slice of commits from a list of messages, it extracts the topic, partition, and offset of each message and builds the corresponding commit slice.

(msgs ...Message)

// the topic, partition, and offset of each message and builds the corresponding
// commit slice.
func makeCommits(msgs ...Message) []commit {
	commits := make([]commit, len(msgs))

	for i, m := range msgs {
		commits[i] = makeCommit(m)
	}

	return commits
}

// commitRequest is the data type exchanged between the CommitMessages method
// and internals of the reader's implementation.