KafkaEventStreamExchange

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