Merge pull request #4751 from navikt/chore/kafka

egen consumer group id
navikt · Dec 6, 2024 · e85fb1f · e85fb1f
2 parents 00af262 + 421ca0c
commit e85fb1f
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 1 deletion.
diff --git a/...no/nav/mulighetsrommet/api/gjennomforing/kafka/DatavarehusGjennomforingV1KafkaProducer.kt b/...no/nav/mulighetsrommet/api/gjennomforing/kafka/DatavarehusGjennomforingV1KafkaProducer.kt
@@ -28,7 +28,7 @@ class DatavarehusGjennomforingV1KafkaProducer(
 
     data class Config(
         val consumerId: String,
-        val consumerGroupId: String? = null,
+        val consumerGroupId: String,
         val consumerTopic: String,
         val producerTopic: String,
     )

diff --git a/mulighetsrommet-api/src/main/resources/application-dev.yaml b/mulighetsrommet-api/src/main/resources/application-dev.yaml
@@ -22,6 +22,7 @@ app:
     clients:
       dvhGjennomforing:
         consumerId: dvh-gjennomforing-consumer
+        consumerGroupId: mulighetsrommet-api.datavarehus-gjennomforing.v1
         consumerTopic: team-mulighetsrommet.siste-tiltaksgjennomforinger-v1
         producerTopic: team-mulighetsrommet.datavarehus-tiltaksgjennomforinger-v1
     consumers:

diff --git a/mulighetsrommet-api/src/main/resources/application-local.yaml b/mulighetsrommet-api/src/main/resources/application-local.yaml
@@ -26,6 +26,7 @@ app:
     clients:
       dvhGjennomforing:
         consumerId: dvh-gjennomforing-consumer
+        consumerGroupId: mulighetsrommet-api.datavarehus-gjennomforing.v1
         consumerTopic: team-mulighetsrommet.siste-tiltaksgjennomforinger-v1
         producerTopic: team-mulighetsrommet.datavarehus-tiltaksgjennomforinger-v1
     consumers:

diff --git a/mulighetsrommet-api/src/main/resources/application-prod.yaml b/mulighetsrommet-api/src/main/resources/application-prod.yaml
@@ -22,6 +22,7 @@ app:
     clients:
       dvhGjennomforing:
         consumerId: dvh-gjennomforing-consumer
+        consumerGroupId: mulighetsrommet-api.datavarehus-gjennomforing.v1
         consumerTopic: team-mulighetsrommet.siste-tiltaksgjennomforinger-v1
         producerTopic: team-mulighetsrommet.datavarehus-tiltaksgjennomforinger-v1
     consumers: