kafka-utils/dev.limebeck.libs.kafka/KafkaListenerProperties

KafkaListenerProperties

data class KafkaListenerProperties<Key, Value>(val bootstrapServers: String, val keyDeserializer: Deserializer<Key>, val valueDeserializer: Deserializer<Value>, val groupId: String, val autoCommit: Boolean = false, val autoOffsetResetStrategy: OffsetResetStrategy = OffsetResetStrategy.EARLIEST, val properties: Properties = Properties())

Constructors

constructor(bootstrapServers: String, keyDeserializer: Deserializer<Key>, valueDeserializer: Deserializer<Value>, groupId: String, autoCommit: Boolean = false, autoOffsetResetStrategy: OffsetResetStrategy = OffsetResetStrategy.EARLIEST, properties: Properties = Properties())