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

Method AddOffsetsToTxn

mocks/sync_producer.go:259–261  ·  view source on GitHub ↗
(offsets map[string][]*sarama.PartitionOffsetMetadata, groupId string)

Source from the content-addressed store, hash-verified

257}
258
259func (sp *SyncProducer) AddOffsetsToTxn(offsets map[string][]*sarama.PartitionOffsetMetadata, groupId string) error {
260 return nil
261}
262
263func (sp *SyncProducer) AddOffsetsToTxnWithGroupMetadata(offsets map[string][]*sarama.PartitionOffsetMetadata, groupMetadata *sarama.ConsumerGroupMetadata) error {
264 return nil

Callers 1

TestSyncProducerUseTxnFunction · 0.95

Implementers 2

syncProducersync_producer.go
SyncProducermocks/sync_producer.go

Calls

no outgoing calls

Tested by 1

TestSyncProducerUseTxnFunction · 0.76