Function makeProduceSet

produce_set_test.go:11–20

()

)

func makeProduceSet() (*asyncProducer, *produceSet) {
	conf := NewTestConfig()
	txnmgr, _ := newTransactionManager(conf, nil)
	parent := &asyncProducer{
		conf:   conf,
		muter:  newPartitionMuter(),
		txnmgr: txnmgr,
	}
	return parent, newProduceSet(parent)
}

func safeAddMessage(t *testing.T, ps *produceSet, msg *ProducerMessage) {
	if err := ps.add(msg); err != nil {