()
| 253 | } |
| 254 | |
| 255 | func (sp *SyncProducer) TxnStatus() sarama.ProducerTxnStatusFlag { |
| 256 | return sp.txnStatus |
| 257 | } |
| 258 | |
| 259 | func (sp *SyncProducer) AddOffsetsToTxn(offsets map[string][]*sarama.PartitionOffsetMetadata, groupId string) error { |
| 260 | return nil |
no outgoing calls