AddOffsetsToTxn add associated offsets to current transaction.
(offsets map[string][]*PartitionOffsetMetadata, groupId string)
| 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 |
no outgoing calls