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

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

Callers 2

Implementers 2

asyncProducerasync_producer.go
AsyncProducermocks/async_producer.go

Calls

no outgoing calls

Tested by 2