diff --git a/modules/stream/src/main/scala/com.snowplowanalytics.snowplow.enrich.stream/model.scala b/modules/stream/src/main/scala/com.snowplowanalytics.snowplow.enrich.stream/model.scala index 85339ad32..a46e7fb29 100644 --- a/modules/stream/src/main/scala/com.snowplowanalytics.snowplow.enrich.stream/model.scala +++ b/modules/stream/src/main/scala/com.snowplowanalytics.snowplow.enrich.stream/model.scala @@ -19,6 +19,7 @@ package com.snowplowanalytics.snowplow.enrich.stream import java.text.SimpleDateFormat +import java.net.URI import cats.syntax.either._ @@ -166,7 +167,7 @@ object model { readTimeout: Option[Long], url: String ) - final case class SentryConfig(dsn: String) + final case class SentryConfig(dsn: URI) final case class EnrichConfig( streams: StreamsConfig, remoteAdapters: Option[List[RemoteAdapterConfig]], diff --git a/modules/stream/src/main/scala/com.snowplowanalytics.snowplow.enrich.stream/sources/Source.scala b/modules/stream/src/main/scala/com.snowplowanalytics.snowplow.enrich.stream/sources/Source.scala index 7df744db2..fa4f040ba 100644 --- a/modules/stream/src/main/scala/com.snowplowanalytics.snowplow.enrich.stream/sources/Source.scala +++ b/modules/stream/src/main/scala/com.snowplowanalytics.snowplow.enrich.stream/sources/Source.scala @@ -122,7 +122,7 @@ abstract class Source( sentryConfig: Option[SentryConfig] ) { - val sentryClient: Option[SentryClient] = sentryConfig.map(_.dsn).map(Sentry.init) + val sentryClient: Option[SentryClient] = sentryConfig.map(_.dsn.toString).map(Sentry.init) val MaxRecordSize: Option[Int]