We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents eaf5210 + df082cc commit b16da86Copy full SHA for b16da86
src/main/kotlin/no/nav/k9/los/fagsystem/k9sak/K9SakStream.kt
@@ -55,9 +55,10 @@ internal class K9SakStream constructor(
55
.stream(
56
fromTopic.name,
57
Consumed.with(fromTopic.keySerde, fromTopic.valueSerde)
58
- ).peek { _, e -> log.info("--> K9SakHendelse: ${e.tryggToString()}") }
59
- .foreach { _, entry ->
+ )
+ .foreach { key, entry ->
60
if (entry != null) {
61
+ log.info("--> K9SakHendelse med key=$key: ${entry.tryggToString()}")
62
TransientFeilHåndterer().utfør(NAME) {
63
runBlocking {
64
k9sakEventHandler.prosesser(entry)
0 commit comments