wow-spring-boot-starter/me.ahoo.wow.spring.boot.starter.kafka/KafkaAutoConfiguration/kafkaCommandBus

kafkaCommandBus

@Bean

@ConditionalOnProperty(value = ["wow.command.bus.type"], matchIfMissing = true, havingValue = "kafka")

fun kafkaCommandBus(topicConverter: CommandTopicConverter, receiverOptionsCustomizer: ReceiverOptionsCustomizer, receiverPolicy: KafkaReceiverPolicy, decodeFailureHandler: TransportDecodeFailureHandler, @Qualifier(value = "kafkaTransportFailurePolicy") failurePolicy: TransportFailurePolicy): DistributedCommandBus