[PubsubPluginSink] Log a sample key and tags when dropping metrics (#250

)
spotify · Feb 26, 2021 · 0a84d10 · 0a84d10
1 parent 7119df9
commit 0a84d10
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/modules/pubsub/src/main/java/com/spotify/ffwd/pubsub/PubsubPluginSink.java b/modules/pubsub/src/main/java/com/spotify/ffwd/pubsub/PubsubPluginSink.java
@@ -146,8 +146,12 @@ public AsyncFuture<Void> sendMetrics(Collection<Metric> metrics) {
         logger.error("Failed to serialize batch of metrics: ", e);
       }
     } else {
-      logger.info("Above input metric limit {}, size was {}; dropping metrics", MAX_INPUT_METRICS,
-       metrics.size());
+      logger.info("Above input metric limit {}, size was {}, sample key: {}, sample tags: {}; "
+      + "dropping metrics",
+       MAX_INPUT_METRICS,
+       metrics.size(),
+       metrics.iterator().next().getKey(),
+       metrics.iterator().next().getTags());
     }
     return async.resolved();
   }