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

Package-level declarations

Types

Link copied to clipboard
@ConditionalOnProperty(value = ["wow.kafka.enabled"], matchIfMissing = true, havingValue = "true")
annotation class ConditionalOnKafkaEnabled
Link copied to clipboard
@AutoConfiguration(before = [CommandAutoConfiguration::class])
@ConditionalOnClass(value = [KafkaCommandBus::class])
@EnableConfigurationProperties(value = [KafkaProperties::class])
class KafkaAutoConfiguration(kafkaProperties: KafkaProperties)
Link copied to clipboard
@ConfigurationProperties(prefix = "wow.kafka")
class KafkaProperties(@DefaultValue(value = ["true"]) var enabled: Boolean = true, var bootstrapServers: List<String>, @DefaultValue(value = ["wow."]) var topicPrefix: String = Wow.WOW_PREFIX, val properties: Map<String, String> = mapOf(), val producer: Map<String, String> = mapOf(), val consumer: Map<String, String> = mapOf(), val receiver: KafkaReceiverProperties = KafkaReceiverProperties()) : EnabledCapable
Link copied to clipboard
class KafkaReceiverProperties(@DefaultValue(value = ["1"]) var prefetchBatches: Int = KafkaReceiverPolicy.DEFAULT_PREFETCH_BATCHES, @DefaultValue(value = ["1"]) var maxDeferredCommits: Int = KafkaReceiverPolicy.DEFAULT_MAX_DEFERRED_COMMITS, @DefaultValue(value = ["3"]) var retryAttempts: Long = KafkaReceiverPolicy.DEFAULT_RETRY_ATTEMPTS, @DefaultValue(value = ["10s"]) var retryBackoff: Duration = KafkaReceiverPolicy.DEFAULT_RETRY_BACKOFF, @DefaultValue(value = ["FAIL"]) var decodeFailureStrategy: KafkaRecordDecodeFailureStrategy = KafkaRecordDecodeFailureStrategy.FAIL)
Link copied to clipboard
Generated by Dokka
© 2026 Copyright