KafkaDomainEventBus
class KafkaDomainEventBus(transport: Transport, topicConverter: EventStreamTopicConverter = DefaultEventStreamTopicConverter(), decodeFailureHandler: TransportDecodeFailureHandler = TransportDecodeFailureHandler.FAIL) : TransportDomainEventBus
The domain event stream bus on Kafka: a TransportDomainEventBus over a KafkaTransport, with topics from topicConverter.
Constructors
Link copied to clipboard
constructor(transport: Transport, topicConverter: EventStreamTopicConverter = DefaultEventStreamTopicConverter(), decodeFailureHandler: TransportDecodeFailureHandler = TransportDecodeFailureHandler.FAIL)
constructor(topicConverter: EventStreamTopicConverter = DefaultEventStreamTopicConverter(), senderOptions: SenderOptions<String, String>, receiverOptions: ReceiverOptions<String, String>, receiverOptionsCustomizer: ReceiverOptionsCustomizer = NoOpReceiverOptionsCustomizer, receiverPolicy: KafkaReceiverPolicy = KafkaReceiverPolicy(), decodeFailureHandler: TransportDecodeFailureHandler = TransportDecodeFailureHandler.FAIL, failurePolicy: TransportFailurePolicy = TransportFailurePolicy.DEFAULT)