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

Method AddMessageToTxn

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

AddMessageToTxn add message offsets to current transaction.

(msg *ConsumerMessage, groupId string, metadata *string)

Source from the content-addressed store, hash-verified

61
62 // AddMessageToTxn add message offsets to current transaction.
63 AddMessageToTxn(msg *ConsumerMessage, groupId string, metadata *string) error
64
65 // AddMessageToTxnWithGroupMetadata adds the message offset to the current
66 // transaction, carrying the consumer group member metadata so the broker

Callers 3

AddMessageToTxnMethod · 0.65
TestProducerWithTxnFunction · 0.65

Implementers 2

syncProducersync_producer.go
SyncProducermocks/sync_producer.go

Calls

no outgoing calls

Tested by 2

TestProducerWithTxnFunction · 0.52