Skip to content

Commit

Permalink
Fjern dependency direkte dependency til felles-logs og felles-kafka
Browse files Browse the repository at this point in the history
  • Loading branch information
sillerud committed Feb 21, 2025
1 parent f79834b commit fc5c0a0
Show file tree
Hide file tree
Showing 3 changed files with 2 additions and 20 deletions.
15 changes: 0 additions & 15 deletions pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -242,26 +242,11 @@
<artifactId>token-validation-core</artifactId>
<version>${token-validation-spring.version}</version>
</dependency>
<dependency>
<groupId>no.nav.familie.felles</groupId>
<artifactId>kafka</artifactId>
<version>${felles.version}</version>
</dependency>
<dependency>
<groupId>no.nav.familie.felles</groupId>
<artifactId>log</artifactId>
<version>${felles.version}</version>
</dependency>
<dependency>
<groupId>no.nav.familie.felles</groupId>
<artifactId>http-client</artifactId>
<version>${felles.version}</version>
</dependency>
<dependency>
<groupId>no.nav.familie.felles</groupId>
<artifactId>sikkerhet</artifactId>
<version>${felles.version}</version>
</dependency>
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-classic</artifactId> <!-- Mulig fiks av snyk-meldinger som gjelder logback-syslog4j -->
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@ import com.fasterxml.jackson.databind.ObjectMapper
import com.fasterxml.jackson.module.kotlin.KotlinModule
import no.nav.familie.http.client.RetryOAuth2HttpClient
import no.nav.familie.http.config.RestTemplateAzure
import no.nav.familie.kafka.KafkaErrorHandler
import no.nav.familie.log.filter.LogFilter
import no.nav.familie.prosessering.config.ProsesseringInfoProvider
import no.nav.security.token.support.client.core.http.OAuth2HttpClient
Expand Down Expand Up @@ -34,7 +33,7 @@ import java.time.temporal.ChronoUnit
@SpringBootConfiguration
@ComponentScan(ApplicationConfig.PAKKE_NAVN, "no.nav.familie.sikkerhet", "no.nav.familie.prosessering", "no.nav.familie.unleash")
@EnableJwtTokenValidation(ignore = ["org.springframework", "org.springdoc"])
@Import(RestTemplateAzure::class, KafkaErrorHandler::class)
@Import(RestTemplateAzure::class)
@EnableOAuth2Client(cacheEnabled = true)
@EnableScheduling
@EnableCaching
Expand Down
4 changes: 1 addition & 3 deletions src/main/kotlin/no/nav/familie/tilbake/config/KafkaConfig.kt
Original file line number Diff line number Diff line change
@@ -1,6 +1,5 @@
package no.nav.familie.tilbake.config

import no.nav.familie.kafka.KafkaErrorHandler
import no.nav.familie.kontrakter.felles.Applikasjon
import org.apache.kafka.clients.CommonClientConfigs
import org.apache.kafka.clients.consumer.ConsumerConfig
Expand Down Expand Up @@ -40,12 +39,11 @@ class KafkaConfig(
fun consumerFactory(): ConsumerFactory<String, String> = DefaultKafkaConsumerFactory(consumerConfigs())

@Bean
fun concurrentKafkaListenerContainerFactory(kafkaErrorHandler: KafkaErrorHandler): ConcurrentKafkaListenerContainerFactory<String, String> {
fun concurrentKafkaListenerContainerFactory(): ConcurrentKafkaListenerContainerFactory<String, String> {
val factory = ConcurrentKafkaListenerContainerFactory<String, String>()
factory.setConcurrency(1)
factory.containerProperties.ackMode = ContainerProperties.AckMode.MANUAL
factory.consumerFactory = consumerFactory()
factory.setCommonErrorHandler(kafkaErrorHandler)
return factory
}

Expand Down

0 comments on commit fc5c0a0

Please sign in to comment.