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

Method AddOffsetsToTxn

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

AddOffsetsToTxn add associated offsets to current transaction.

(offsets map[string][]*PartitionOffsetMetadata, groupId string)

Source from the content-addressed store, hash-verified

53
54 // AddOffsetsToTxn add associated offsets to current transaction.
55 AddOffsetsToTxn(offsets map[string][]*PartitionOffsetMetadata, groupId string) error
56
57 // AddOffsetsToTxnWithGroupMetadata adds associated offsets to the current
58 // transaction, carrying the consumer group member metadata so the broker

Callers 3

AddOffsetsToTxnMethod · 0.65
publishOffsetsToTxnMethod · 0.65
TestProducerWithTxnFunction · 0.65

Implementers 2

syncProducersync_producer.go
SyncProducermocks/sync_producer.go

Calls

no outgoing calls

Tested by 1

TestProducerWithTxnFunction · 0.52