Method AbortTxn

async_producer.go:80–80 · view source on GitHub ↗

AbortTxn abort current transaction.

()

Source from the content-addressed store, hash-verified

78
79	// AbortTxn abort current transaction.
80	AbortTxn() error
81
82	// AddOffsetsToTxn add associated offsets to current transaction.
83	AddOffsetsToTxn(offsets map[string][]*PartitionOffsetMetadata, groupId string) error

TestFuncTxnCommitNoMessagesFunction · 0.95

TestFuncTxnProduceMultiTxnFunction · 0.95

asyncProducerasync_producer.go

AsyncProducermocks/async_producer.go

no outgoing calls

TestFuncTxnCommitNoMessagesFunction · 0.76

TestFuncTxnProduceMultiTxnFunction · 0.76