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

KafkaAutoConfiguration

@AutoConfiguration(before = [CommandAutoConfiguration::class])
@ConditionalOnClass(value = [KafkaCommandBus::class])
@EnableConfigurationProperties(value = [KafkaProperties::class])
class KafkaAutoConfiguration(kafkaProperties: KafkaProperties)

Constructors

Link copied to clipboard
constructor(kafkaProperties: KafkaProperties)

Functions

Link copied to clipboard
@Bean
@ConditionalOnMissingBean
fun defaultCommandTopicConverter(): CommandTopicConverter
Link copied to clipboard
@Bean
@ConditionalOnMissingBean
fun defaultEventStreamTopicConverter(): EventStreamTopicConverter
Link copied to clipboard
@Bean
@ConditionalOnProperty(value = ["wow.command.bus.type"], matchIfMissing = true, havingValue = "kafka")
fun kafkaCommandBus(topicConverter: CommandTopicConverter, receiverOptionsCustomizer: ReceiverOptionsCustomizer): DistributedCommandBus
Link copied to clipboard
@Bean
@ConditionalOnProperty(value = ["wow.event.bus.type"], matchIfMissing = true, havingValue = "kafka")
fun kafkaDomainEventBus(topicConverter: EventStreamTopicConverter, receiverOptionsCustomizer: ReceiverOptionsCustomizer): DistributedDomainEventBus
Link copied to clipboard
@Bean
@ConditionalOnProperty(value = ["wow.eventsourcing.state.bus.type"], matchIfMissing = true, havingValue = "kafka")
fun kafkaStateEventBus(topicConverter: StateEventTopicConverter, receiverOptionsCustomizer: ReceiverOptionsCustomizer): DistributedStateEventBus
Link copied to clipboard
@Bean
@ConditionalOnMissingBean
fun receiverOptionsCustomizer(): ReceiverOptionsCustomizer
Link copied to clipboard
@Bean
@ConditionalOnMissingBean
fun stateEventTopicConverter(): StateEventTopicConverter