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

Package-level declarations

Types

data class KafkaConsumerConfig(val applicationId: String = requiredConfigForKey("NAIS_APP_NAME"), val maxPollRecords: Int = 1, val autoOffsetReset: String = "earliest", val enableAutoCommit: Boolean = false, val brokers: String = requiredConfigForKey("KAFKA_BROKERS"), val ssl: SslConfig? = SslConfig(), val schemaRegistry: SchemaRegistryConfig? = SchemaRegistryConfig(), val compressionType: String = "snappy", val additionalProperties: Properties = Properties(), val keyDeserializer: Class<out Deserializer<*>> = StringDeserializer::class.java, val valueDeserializer: Class<out Deserializer<*>> = StringDeserializer::class.java)

KafkaKonsument

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

SchemaRegistryConfig

data class SchemaRegistryConfig(val url: String = requiredConfigForKey("KAFKA_SCHEMA_REGISTRY"), val user: String = requiredConfigForKey("KAFKA_SCHEMA_REGISTRY_USER"), val password: String = requiredConfigForKey("KAFKA_SCHEMA_REGISTRY_PASSWORD"))

SslConfig

data class SslConfig(val truststorePath: String = requiredConfigForKey("KAFKA_TRUSTSTORE_PATH"), val keystorePath: String = requiredConfigForKey("KAFKA_KEYSTORE_PATH"), val credstorePsw: String = requiredConfigForKey("KAFKA_CREDSTORE_PASSWORD"))