TilbakekrevingKafkaKonsument

class TilbakekrevingKafkaKonsument(config: KafkaConsumerConfig, pollTimeout: Duration = 10.seconds, closeTimeout: Duration = 30.seconds, val dataSource: DataSource, val repositoryRegistry: RepositoryRegistry) : KafkaKonsument<String, String> (source)

Constructors

constructor(config: KafkaConsumerConfig, pollTimeout: Duration = 10.seconds, closeTimeout: Duration = 30.seconds, dataSource: DataSource, repositoryRegistry: RepositoryRegistry)

private val konsument: KafkaConsumer<K, V>

private val log: Logger?

private val repositoryRegistry: RepositoryRegistry

private val secureLogger: Logger?

fun håndter(melding: ConsumerRecord<String, String>)

open override fun håndter(meldinger: ConsumerRecords<String, String>)

fun håndter(meldingKey: String, meldingVerdi: String)

fun lukk()