MCPcopy
hub / github.com/IBM/sarama / AbortTxn

Method AbortTxn

sync_producer.go:52–52  ·  view source on GitHub ↗

AbortTxn abort current transaction.

()

Source from the content-addressed store, hash-verified

50
51 // AbortTxn abort current transaction.
52 AbortTxn() error
53
54 // AddOffsetsToTxn add associated offsets to current transaction.
55 AddOffsetsToTxn(offsets map[string][]*PartitionOffsetMetadata, groupId string) error

Callers 7

TestFuncTxnAbortedProduceFunction · 0.65
AbortTxnMethod · 0.65
TestTxnProduceBumpEpochFunction · 0.65
TestTxnProduceRecordWithAbortFunction · 0.65
TestTxnCanAbortFunction · 0.65
produceTestRecordFunction · 0.65
handleTxnErrorMethod · 0.65

Implementers 2

syncProducersync_producer.go
SyncProducermocks/sync_producer.go

Calls

no outgoing calls

Tested by 4

TestFuncTxnAbortedProduceFunction · 0.52
TestTxnProduceBumpEpochFunction · 0.52
TestTxnProduceRecordWithAbortFunction · 0.52
TestTxnCanAbortFunction · 0.52