Method MessageRequiresConsistency

partitioner.go:38–38

MessageRequiresConsistency is similar to Partitioner.RequiresConsistency, but takes in the message being partitioned so that the partitioner can make a per-message determination.

(message *ProducerMessage)

	// but takes in the message being partitioned so that the partitioner can
	// make a per-message determination.
	MessageRequiresConsistency(message *ProducerMessage) bool
}

// PartitionerConstructor is the type for a function capable of constructing new Partitioners.