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

Package-level declarations

Types

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

@ConditionalOnClass(value = [KafkaCommandBus::class])

@EnableConfigurationProperties(value = [KafkaProperties::class])

@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()) : EnabledCapable