KafkaStateEventExchange

class KafkaStateEventExchange<S : Any>(val message: StateEvent<S>, receiverOffset: ReceiverOffset, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : StateEventExchange<S>

Constructors

constructor(message: StateEvent<S>, receiverOffset: ReceiverOffset, attributes: MutableMap<String, Any> = ConcurrentHashMap())

open override val message: StateEvent<S>

open override fun acknowledge(): Mono<Void>