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

KafkaListenerProperties

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