TopicMessage

class TopicMessage @InternalWowApi constructor(val key: String, val value: ByteArray, val headers: Map<String, String> = emptyMap(), val partition: Int? = null)

A message to write to a topic: its key, which picks its partition (the same key always lands in the same partition, so the messages of one key keep their order), its headers and its value bytes.

partition, when set, is the partition the message goes to instead of the one its key picks: a command topic's partitions are the context's log partitions, chosen by the log's own partitioner.

Constructors

Link copied to clipboard
constructor(key: String, value: ByteArray, headers: Map<String, String> = emptyMap(), partition: Int? = null)

Types

Link copied to clipboard
object Companion

Properties

Link copied to clipboard
Link copied to clipboard
val key: String
Link copied to clipboard
Link copied to clipboard

Functions

Link copied to clipboard
open operator override fun equals(other: Any?): Boolean
Link copied to clipboard
open override fun hashCode(): Int
Link copied to clipboard
open override fun toString(): String