From dfc2fc5171c909e0b275b78456399af994d2fa2d Mon Sep 17 00:00:00 2001 From: Benjamin Benoist Date: Wed, 2 Aug 2023 14:20:36 +0200 Subject: [PATCH] PubSub: use debug for logging the inserts (close #321) --- .../sinks/GooglePubSubSink.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pubsub/src/main/scala/com.snowplowanalytics.snowplow.collectors.scalastream/sinks/GooglePubSubSink.scala b/pubsub/src/main/scala/com.snowplowanalytics.snowplow.collectors.scalastream/sinks/GooglePubSubSink.scala index eb12a78c2..76b69d4a5 100644 --- a/pubsub/src/main/scala/com.snowplowanalytics.snowplow.collectors.scalastream/sinks/GooglePubSubSink.scala +++ b/pubsub/src/main/scala/com.snowplowanalytics.snowplow.collectors.scalastream/sinks/GooglePubSubSink.scala @@ -62,7 +62,7 @@ class GooglePubSubSink private ( override def storeRawEvents(events: List[Array[Byte]], key: String): Unit = if (events.nonEmpty) { - log.info(s"Writing ${events.size} records to PubSub topic $topicName") + log.debug(s"Writing ${events.size} records to PubSub topic $topicName") events.foreach { event => publisher.asRight.map { p =>