KafkaStateEventBus
constructor(topicConverter: StateEventTopicConverter, senderOptions: SenderOptions<String, String>, receiverOptions: ReceiverOptions<String, String>, receiverOptionsCustomizer: ReceiverOptionsCustomizer, receiverPolicy: KafkaReceiverPolicy, recordDecodeFailureHandler: KafkaRecordDecodeFailureHandler)
constructor(topicConverter: StateEventTopicConverter = DefaultStateEventTopicConverter(), senderOptions: SenderOptions<String, String>, receiverOptions: ReceiverOptions<String, String>, receiverOptionsCustomizer: ReceiverOptionsCustomizer = NoOpReceiverOptionsCustomizer)