()
| 203 | } |
| 204 | |
| 205 | func (sp *syncProducer) AbortTxn() error { |
| 206 | return sp.producer.AbortTxn() |
| 207 | } |
| 208 | |
| 209 | func (sp *syncProducer) AddOffsetsToTxn(offsets map[string][]*PartitionOffsetMetadata, groupId string) error { |
| 210 | return sp.producer.AddOffsetsToTxn(offsets, groupId) |