api/no.nav.aap.behandlingsflyt.hendelse.kafka/KafkaKonsument

KafkaKonsument

abstract class KafkaKonsument<K, V>(val topic: String, config: KafkaConsumerConfig, consumerName: String, val pollTimeout: Duration, val closeTimeout: Duration)(source)

Inheritors

ForeldrepengevedtakKafkaKonsument

InstitusjonsOppholdKafkaKonsument

KabalKafkaKonsument

PdlHendelseKafkaKonsument

SykepengevedtakKafkaKonsument

TilbakekrevingKafkaKonsument

UførevedtakKafkaKonsument

Constructors

constructor(topic: String, config: KafkaConsumerConfig, consumerName: String, pollTimeout: Duration, closeTimeout: Duration)

Properties

antallMeldinger

var antallMeldinger: Int

private val closeTimeout: Duration

private val konsument: KafkaConsumer<K, V>

private val log: Logger?

private val lukket: AtomicBoolean

private val pollTimeout: Duration

val topic: String

Functions

fun erLukket(): Boolean

abstract fun håndter(meldinger: ConsumerRecords<K, V>)

fun lukk()