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