behandlingsflyt/no.nav.aap.behandlingsflyt.prosessering.tilbakekreving/KafkaProdusent

KafkaProdusent

abstract class KafkaProdusent<K, V>(val topic: String, config: KafkaProducerConfig<K, V>, producerName: String)(source)

Inheritors

TilbakekrevingFagsystemInfoProdusent

Constructors

constructor(topic: String, config: KafkaProducerConfig<K, V>, producerName: String)

Properties

private val log: Logger?

private val produsent: KafkaProducer<K, V>

val topic: String

Functions

fun produser(key: K, value: V)