StreamRecord

data class StreamRecord<K, V>(val key: K, val value: V, val ts: Long = System.currentTimeMillis())

Constructors

constructor(key: K, value: V, ts: Long = System.currentTimeMillis())

val key: K