TransportRecord

One received record. ack confirms it to the broker (Kafka offset commit, Redis XACK); nack gives it up without confirming, so the broker's own redelivery applies (a Kafka offset that is never committed, a Redis entry that stays pending).

Properties

Link copied to clipboard
abstract val id: String

The backend position of this record, for logs (Kafka partition-offset, a Redis entry ID).

Link copied to clipboard
abstract val key: String?

The record key; null on a backend without keys, or on a keyed record published without one.

Link copied to clipboard
open val keyed: Boolean

Whether the backend has record keys. A keyed record's key must equal the decoded message's aggregate ID (a missing key does not); Redis Streams records are not keyed.

Link copied to clipboard
abstract val payload: String?

The encoded message, or null when the backend record carries none.

Link copied to clipboard
abstract val topic: String

Functions

Link copied to clipboard
abstract fun ack(): Mono<Void>
Link copied to clipboard
open fun nack(): Mono<Void>