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, WowProperties::class])

class KafkaAutoConfiguration(kafkaProperties: KafkaProperties, wowProperties: WowProperties)

Constructors

KafkaAutoConfiguration

constructor(kafkaProperties: KafkaProperties, wowProperties: WowProperties)

Types

Companion

object Companion

Functions

defaultCommandTopicConverter

@Bean

@ConditionalOnMissingBean

fun defaultCommandTopicConverter(): CommandTopicConverter

defaultEventStreamTopicConverter

@Bean

@ConditionalOnMissingBean

fun defaultEventStreamTopicConverter(): EventStreamTopicConverter

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

kafkaCommandBusRuntimeResource

@Bean

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

fun kafkaCommandBusRuntimeResource(@Qualifier(value = "kafkaCommandBus") kafkaCommandBus: DistributedCommandBus): RuntimeResource

kafkaDomainEventBus

@Bean

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

fun kafkaDomainEventBus(topicConverter: EventStreamTopicConverter, receiverOptionsCustomizer: ReceiverOptionsCustomizer, receiverPolicy: KafkaReceiverPolicy, decodeFailureHandler: TransportDecodeFailureHandler, @Qualifier(value = "kafkaTransportFailurePolicy") failurePolicy: TransportFailurePolicy): DistributedDomainEventBus

kafkaDomainEventBusRuntimeResource

@Bean

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

fun kafkaDomainEventBusRuntimeResource(@Qualifier(value = "kafkaDomainEventBus") kafkaDomainEventBus: DistributedDomainEventBus): RuntimeResource

kafkaReceiverPolicy

@Bean

@ConditionalOnMissingBean

fun kafkaReceiverPolicy(): KafkaReceiverPolicy

kafkaRecordDecodeFailureHandler

@Bean

@ConditionalOnMissingBean

fun kafkaRecordDecodeFailureHandler(): TransportDecodeFailureHandler

kafkaStateEventBus

@Bean

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

fun kafkaStateEventBus(topicConverter: StateEventTopicConverter, receiverOptionsCustomizer: ReceiverOptionsCustomizer, receiverPolicy: KafkaReceiverPolicy, decodeFailureHandler: TransportDecodeFailureHandler, @Qualifier(value = "kafkaTransportFailurePolicy") failurePolicy: TransportFailurePolicy): DistributedStateEventBus

kafkaStateEventBusRuntimeResource

@Bean

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

fun kafkaStateEventBusRuntimeResource(@Qualifier(value = "kafkaStateEventBus") kafkaStateEventBus: DistributedStateEventBus): RuntimeResource

kafkaTransportFailurePolicy

@Bean(value = ["kafkaTransportFailurePolicy"])

@ConditionalOnMissingBean(name = ["kafkaTransportFailurePolicy"])

fun kafkaTransportFailurePolicy(): TransportFailurePolicy

receiverOptionsCustomizer

@Bean

@ConditionalOnMissingBean

fun receiverOptionsCustomizer(): ReceiverOptionsCustomizer

stateEventTopicConverter

@Bean

@ConditionalOnMissingBean

fun stateEventTopicConverter(): StateEventTopicConverter