MCPcopy
hub / github.com/segmentio/kafka-go / Transaction

Method Transaction

protocol/protocol.go:499–499  ·  view source on GitHub ↗

Returns the transactional id configured on the message.

()

Source from the content-addressed store, hash-verified

497type TransactionalMessage interface {
498 // Returns the transactional id configured on the message.
499 Transaction() string
500}
501
502// PreparedMessage is an extension of the Message interface implemented by some

Callers 1

sendRequestMethod · 0.65

Implementers 4

Requestprotocol/endtxn/endtxn.go
Requestprotocol/addoffsetstotxn/addoffsetstot
Requestprotocol/initproducerid/initproducerid
Requestprotocol/addpartitionstotxn/addpartiti

Calls

no outgoing calls

Tested by

no test coverage detected