kafka

const (
	// PartitionKeySchema keys messages by schema name. All events for a given
	// schema are routed to the same partition, which guarantees ordering per
	// schema. This is the default.
	PartitionKeySchema PartitionKey = "schema"
	// PartitionKeyTable keys messages by schema qualified table name. Events
	// for a given table are routed to the same partition, which guarantees
	// ordering per table, but not across tables in the same schema.
	PartitionKeyTable PartitionKey = "table"
	// PartitionKeyPrimaryKey keys messages by schema qualified table name and
	// the event primary key values. Events for a given row are routed to the
	// same partition, which guarantees ordering per row, but not across rows
	// or against DDL events. Events without an identifiable primary key
	// degrade to table keying.
	PartitionKeyPrimaryKey PartitionKey = "primary_key"
)