TransportMessage
data class TransportMessage(val topic: String, val key: String, val payload: String, val timestamp: Long, val headers: Map<String, String> = emptyMap())
One outbound record. Records with one key stay in order; timestamp is the message's creation time in epoch milliseconds. A backend writes what it supports: Kafka writes all of it, Redis Streams only topic and payload.