spi/me.ahoo.wow.spi.transport/SourceMessage

SourceMessage

class SourceMessage @InternalWowApi constructor(val offset: Long, val key: String?, val headers: Map<String, String>, val value: ByteArray)

A message read from a partition of a topic at its offset, with its key (null when it has none).

Constructors

@InternalWowApi

constructor(offset: Long, key: String?, headers: Map<String, String>, value: ByteArray)

Types

object Companion

Properties

val headers: Map<String, String>

val key: String?

val offset: Long

val value: ByteArray

Functions

open operator override fun equals(other: Any?): Boolean

open override fun hashCode(): Int

open override fun toString(): String