AddMessageToTxn add message offsets to current transaction.
(msg *ConsumerMessage, groupId string, metadata *string)
| 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 |
no outgoing calls