KafkaEventStreamExchange

data class KafkaEventStreamExchange(val message: DomainEventStream, receiverOffset: ReceiverOffset, val attributes: MutableMap<String, Any> = ConcurrentHashMap()) : EventStreamExchange

Constructors

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

open override fun acknowledge(): Mono<Void>