api/no.nav.aap.behandlingsflyt.hendelse.kafka.person/PdlHendelseKafkaKonsument

PdlHendelseKafkaKonsument

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

Constructors

PdlHendelseKafkaKonsument

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

Types

enum Dødsfalltype(val verdi: String) : Enum<PdlHendelseKafkaKonsument.Dødsfalltype>

Properties

antallMeldinger

var antallMeldinger: Int

private val closeTimeout: Duration

private val dataSource: DataSource

gatewayProvider

private val gatewayProvider: GatewayProvider

private val konsument: KafkaConsumer<K, V>

private val log: Logger?

private val log: Logger?

private val lukket: AtomicBoolean

private val pollTimeout: Duration

repositoryRegistry

private val repositoryRegistry: RepositoryRegistry

val topic: String

Functions

fun erLukket(): Boolean

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

fun lukk()

fun Personhendelse.tilDomain(): PdlPersonHendelse