queue

type AsyncConsumer interface {
	// Start start the consumer
	Start(cb func(uint32, uint64, [][]byte))
	// Commit commit completed offset
	Commit(map[uint32]uint64, func(error))
	// CommitPartition commit completed offset
	CommitPartition(uint32, uint64, func(error))
	// Stop stop consumer
	Stop()
}

type Consumer interface {
	// Start start the consumer
	Start(batch uint64, cb func(uint32, uint64, ...[]byte) (uint64, error))
	// Stop stop consumer
	Stop()
}