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

KafkaProperties

@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, var properties: Map<String, String> = mapOf(), var producer: Map<String, String> = mapOf(), var consumer: Map<String, String> = mapOf(), var receiver: KafkaReceiverProperties = KafkaReceiverProperties(), var closeTimeout: Duration? = null) : EnabledCapable

Constructors

KafkaProperties

constructor(@DefaultValue(value = ["true"]) enabled: Boolean = true, bootstrapServers: List<String>, @DefaultValue(value = ["wow."]) topicPrefix: String = Wow.WOW_PREFIX, properties: Map<String, String> = mapOf(), producer: Map<String, String> = mapOf(), consumer: Map<String, String> = mapOf(), receiver: KafkaReceiverProperties = KafkaReceiverProperties(), closeTimeout: Duration? = null)

Types

Companion

object Companion

Properties

bootstrapServers

var bootstrapServers: List<String>

closeTimeout

var closeTimeout: Duration?

How long closing a producer may wait to flush its buffered records. Unset, the starter uses wow.shutdown-timeout, so a close never outlasts the runtime's shutdown deadline (the Kafka client's own default waits without bound).

consumer

var consumer: Map<String, String>

enabled

open override var enabled: Boolean

producer

var producer: Map<String, String>

properties

var properties: Map<String, String>

common properties

receiver

@NestedConfigurationProperty

var receiver: KafkaReceiverProperties