Skip to content

Commit

Permalink
kan angi meter registry
Browse files Browse the repository at this point in the history
  • Loading branch information
davidsteinsland committed Oct 31, 2024
1 parent 50d7efb commit c7f281c
Showing 1 changed file with 1 addition and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -129,10 +129,9 @@ class RapidApplication internal constructor(
fun create(
env: Map<String, String>,
consumerProducerFactory: ConsumerProducerFactory = ConsumerProducerFactory(AivenConfig.default),
meterRegistry: PrometheusMeterRegistry = PrometheusMeterRegistry(PrometheusConfig.DEFAULT, PrometheusRegistry.defaultRegistry, Clock.SYSTEM),
configure: (ApplicationEngine, KafkaRapid) -> Unit = { _, _ -> }
): RapidsConnection {
val meterRegistry = PrometheusMeterRegistry(PrometheusConfig.DEFAULT, PrometheusRegistry.defaultRegistry, Clock.SYSTEM)

val kafkaRapid = createDefaultKafkaRapidFromEnv(
factory = consumerProducerFactory,
meterRegistry = meterRegistry,
Expand Down

0 comments on commit c7f281c

Please sign in to comment.