Skip to content

Commit

Permalink
monitor flytte til application
Browse files Browse the repository at this point in the history
  • Loading branch information
robertkittilsen committed Dec 23, 2024
1 parent 7ab7d8e commit 27212cf
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -69,7 +69,7 @@ fun <K, V> kafkaConsumerPlugin(): ApplicationPlugin<KafkaConsumerPluginConfig<K,
on(MonitoringEvent(ApplicationStarted)) { application ->
logger.info("Kafka Consumer klargjøres")
kafkaConsumer.subscribe(kafkaTopics, rebalanceListener)
application.environment.monitor.raise(KafkaConsumerReady, application)
application.monitor.raise(KafkaConsumerReady, application)
}

on(MonitoringEvent(ApplicationStopping)) { _ ->
Expand Down

0 comments on commit 27212cf

Please sign in to comment.