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, val properties: Map<String, String> = mapOf(), val producer: Map<String, String> = mapOf(), val consumer: Map<String, String> = mapOf()) : EnabledCapable

Constructors

Link copied to clipboard
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())

Types

Link copied to clipboard
object Companion

Properties

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
open override var enabled: Boolean
Link copied to clipboard
Link copied to clipboard

common properties

Link copied to clipboard

Functions

Link copied to clipboard
Link copied to clipboard
fun buildReceiverOptions(): ReceiverOptions<String, String>
Link copied to clipboard
fun buildSenderOptions(): SenderOptions<String, String>