func (m *Message) CommitToken() CommitToken {
	return CommitToken{
		topic:  m.Topic,
		partID: int(m.Partition),
		offset: m.Offset,
	}
}
CommitToken returns a CommitToken for a message. This can be passed to the
CommitByToken method.
package marshal
import (
	"errors"
	"fmt"
	"math/rand"
	"sync"
	"sync/atomic"
	"time"
	"github.com/zorkian/kafka/proto"
)
type CommitToken struct {
	topic  string
	partID int
	offset int64
}
type Message proto.Message