Improve logging

Author: LofhJann

src/main/java/fi/hsl/transitdata/stopestimates/MessageHandler.java

@@ -36,7 +36,6 @@ public void handleMessage(Message received) throws Exception {
                 final List<InternalMessages.StopEstimate> stopEstimates = maybeStopEstimates.get();
                 stopEstimates.forEach(stopEstimate -> sendPulsarMessage(messageId, stopEstimate, timestamp, key));
             } else {
-                log.warn("Received unexpected schema, ignoring.");
                 ack(received.getMessageId()); //Ack so we don't receive it again
             }
         } catch (Exception e) {
@@ -57,7 +56,7 @@ private void sendPulsarMessage(MessageId received, InternalMessages.StopEstimate
 
         String routeId = estimate.getTripInfo().getRouteId();
         if (routeId.contains("31M")) {
-            log.info("Found metro trip. RouteId: {}", routeId);
+            log.debug("Found metro trip. RouteId: {}", routeId);
         }
 
         producer.newMessage()

src/main/java/fi/hsl/transitdata/stopestimates/PubtransStopEstimatesFactory.java

@@ -89,7 +89,7 @@ private static boolean validateCommon(PubtransTableProtos.Common common) {
             return false;
         }
         if (common.getType() == 0) {
-            log.info("Event is for a via point, message discarded");
+            log.debug("Event is for a via point, message discarded");
             return false;
         }
         return true;