Send Kafka-key til behov-rivers som aktiveres i parallell #797
Conversation
|
Testet OK. |
| @@ -192,6 +192,7 @@ private object Mock { | |||
| mapOf( | |||
| Key.ORGNR_UNDERENHETER to orgnr.toJson(Orgnr.serializer()), | |||
| ), | |||
| svarKafkaKey = null, | |||
There was a problem hiding this comment.
Er den null fordi det ikke er noen partisjonering i test og den dermed ikke blir brukt til noe?
Eller er det noen tilfeller denne er null i prod også?
There was a problem hiding this comment.
Den kan være null i prod også, foreløpig. Nå er det kun servicene med state som må bruke svarKafkaKey, mens de uten state ikke trenger det. Det er mulig at det er bedre om alle bruker det, men det tenkte jeg å se på etter denne PR-en.
| operator fun invoke(forespoerselId: UUID): KafkaKey = KafkaKey(forespoerselId.toString()) | ||
|
|
||
| operator fun invoke(sykmeldtFnr: Fnr): KafkaKey = KafkaKey(sykmeldtFnr.verdi) |
There was a problem hiding this comment.
Snedig. Dette er for å slippe .toString() og .verdi rundt om kring i koden?
There was a problem hiding this comment.
Det er mer for å håndheve en streng type. Hvis man har lov til å bruke en hvilken som helst streng som Kafka-nøkkel så blir det ville vesten 🤠
(Jeg prøvde å lage to constructor, men det går ikke pga. konflikt under kompileringen til Java, derav invoke.)
| @@ -54,6 +57,7 @@ class HentInntektRiver( | |||
| behovType = Key.BEHOV.krev(BehovType.HENT_INNTEKT, BehovType.serializer(), json), | |||
| transaksjonId = Key.KONTEKST_ID.les(UuidSerializer, json), | |||
| data = data, | |||
| svarKafkaKey = Key.SVAR_KAFKA_KEY.lesOrNull(KafkaKey.serializer(), data), | |||
There was a problem hiding this comment.
Er det sånn at vi i først neste omgang/PR faktisk skal publisere meldinger med denne nøkkelen, og at dette bare er foreberedelsene?
Jeg forsøkte å grave meg litt ned i riveren og kom til den linja her: ?.also { context.publish(null, it) } i OpenRiver.kt. Er det der vi etter hvert skal sende inn denne nøkkelen?
There was a problem hiding this comment.
Det stemmer at dette er forberedelser. null i context.publish(null, it) må byttes ut med en verdi. For alle som får svarKafkaKey, så skal vi bruke den verdien. For resterende så er ikke løsningen helt klar.
Kafka-keysene som sendes skal brukes i meldingen som behov-riverene sender som svar. Kort sagt så må alle behov-riverne som svarer en spesifikk service bruke den samme nøkkelen, slik at alle svarene går til den samme servicen. Nøkkelen må også være den samme for en forespørsel/sykmeldt på tvers av kall til API-et, slik at meldingene leses i samme rekkefølgen som de skrives.