Method AddMessageToTxnWithGroupMetadata

sync_producer.go:68–68

AddMessageToTxnWithGroupMetadata adds the message offset to the current transaction, carrying the consumer group member metadata so the broker can fence stale members (KIP-447).

(msg *ConsumerMessage, groupMetadata *ConsumerGroupMetadata, metadata *string)

	// transaction, carrying the consumer group member metadata so the broker
	// can fence stale members (KIP-447).
	AddMessageToTxnWithGroupMetadata(msg *ConsumerMessage, groupMetadata *ConsumerGroupMetadata, metadata *string) error
}

type syncProducer struct {