kotka-streams-extensions/dev.adamko.kotka.extensions.processor

Package-level declarations

Functions

Link copied to clipboard
operator fun <K, V> Record<K, V>.component1(): K

Get the key of a Record

Link copied to clipboard
operator fun <K, V> Record<K, V>.component2(): V

Get the value of a Record

Link copied to clipboard
operator fun <K, V> Record<K, V>.component3(): Long

Get the timestamp of a Record