wow-kafka/me.ahoo.wow.kafka/KafkaDomainEventBus/KafkaDomainEventBus

KafkaDomainEventBus

constructor(topicConverter: EventStreamTopicConverter = DefaultEventStreamTopicConverter(), senderOptions: SenderOptions<String, String>, receiverOptions: ReceiverOptions<String, String>, receiverOptionsCustomizer: ReceiverOptionsCustomizer = NoOpReceiverOptionsCustomizer)