Removed redundant logging

application/src/main/java/org/thingsboard/server/actors/service/DefaultActorService.java

@@ -201,7 +201,11 @@ public class DefaultActorService implements ActorService {
     @Scheduled(fixedDelayString = "${cluster.stats.print_interval_ms}")
     public void printStats() {
         if (statsEnabled) {
-            log.info("Cluster msgs sent [{}] received [{}]", sentClusterMsgs.getAndSet(0), receivedClusterMsgs.getAndSet(0));
+            int sent = sentClusterMsgs.getAndSet(0);
+            int received = receivedClusterMsgs.getAndSet(0);
+            if (sent > 0 || received > 0) {
+                log.info("Cluster msgs sent [{}] received [{}]", sent, received);
+            }
         }
     }
 

application/src/main/java/org/thingsboard/server/service/script/RemoteJsInvokeService.java

@@ -87,12 +87,15 @@ public class RemoteJsInvokeService extends AbstractJsInvokeService {
     @Scheduled(fixedDelayString = "${js.remote.stats.print_interval_ms}")
     public void printStats() {
         if (statsEnabled) {
+            int pushedMsgs = kafkaPushedMsgs.getAndSet(0);
             int invokeMsgs = kafkaInvokeMsgs.getAndSet(0);
             int evalMsgs = kafkaEvalMsgs.getAndSet(0);
             int failed = kafkaFailedMsgs.getAndSet(0);
             int timedOut = kafkaTimeoutMsgs.getAndSet(0);
-            log.info("Kafka JS Invoke Stats: pushed [{}] received [{}] invoke [{}] eval [{}] failed [{}] timedOut [{}]",
-                    kafkaPushedMsgs.getAndSet(0), invokeMsgs + evalMsgs, invokeMsgs, evalMsgs, failed, timedOut);
+            if (pushedMsgs > 0 || invokeMsgs > 0 || evalMsgs > 0 || failed > 0 || timedOut > 0) {
+                log.info("Kafka JS Invoke Stats: pushed [{}] received [{}] invoke [{}] eval [{}] failed [{}] timedOut [{}]",
+                        pushedMsgs, invokeMsgs + evalMsgs, invokeMsgs, evalMsgs, failed, timedOut);
+            }
         }
     }
 

application/src/main/java/org/thingsboard/server/service/transport/RuleEngineStats.java

@@ -70,11 +70,14 @@ public class RuleEngineStats {
     }
 
     public void printStats() {
-        log.info("Transport total [{}] sessionEvents [{}] telemetry [{}] attributes [{}] getAttr [{}] subToAttr [{}] subToRpc [{}] toDevRpc [{}] " +
-                        "toServerRpc [{}] subInfo [{}] claimDevice [{}] ",
-                totalCounter.getAndSet(0), sessionEventCounter.getAndSet(0), postTelemetryCounter.getAndSet(0),
-                postAttributesCounter.getAndSet(0), getAttributesCounter.getAndSet(0), subscribeToAttributesCounter.getAndSet(0),
-                subscribeToRPCCounter.getAndSet(0), toDeviceRPCCallResponseCounter.getAndSet(0),
-                toServerRPCCallRequestCounter.getAndSet(0), subscriptionInfoCounter.getAndSet(0), claimDeviceCounter.getAndSet(0));
+        int total = totalCounter.getAndSet(0);
+        if (total > 0) {
+            log.info("Transport total [{}] sessionEvents [{}] telemetry [{}] attributes [{}] getAttr [{}] subToAttr [{}] subToRpc [{}] toDevRpc [{}] " +
+                            "toServerRpc [{}] subInfo [{}] claimDevice [{}] ",
+                    total, sessionEventCounter.getAndSet(0), postTelemetryCounter.getAndSet(0),
+                    postAttributesCounter.getAndSet(0), getAttributesCounter.getAndSet(0), subscribeToAttributesCounter.getAndSet(0),
+                    subscribeToRPCCounter.getAndSet(0), toDeviceRPCCallResponseCounter.getAndSet(0),
+                    toServerRPCCallRequestCounter.getAndSet(0), subscriptionInfoCounter.getAndSet(0), claimDeviceCounter.getAndSet(0));
+        }
     }
 }

dao/src/main/java/org/thingsboard/server/dao/nosql/CassandraBufferedRateExecutor.java

@@ -64,12 +64,24 @@ public class CassandraBufferedRateExecutor extends AbstractBufferedRateExecutor<
 
     @Scheduled(fixedDelayString = "${cassandra.query.rate_limit_print_interval_ms}")
     public void printStats() {
-        log.info("Permits queueSize [{}] totalAdded [{}] totalLaunched [{}] totalReleased [{}] totalFailed [{}] totalExpired [{}] totalRejected [{}] " +
-                        "totalRateLimited [{}] totalRateLimitedTenants [{}] currBuffer [{}] ",
-                getQueueSize(),
-                totalAdded.getAndSet(0), totalLaunched.getAndSet(0), totalReleased.getAndSet(0),
-                totalFailed.getAndSet(0), totalExpired.getAndSet(0), totalRejected.getAndSet(0),
-                totalRateLimited.getAndSet(0), rateLimitedTenants.size(), concurrencyLevel.get());
+        int queueSize = getQueueSize();
+        int totalAddedValue = totalAdded.getAndSet(0);
+        int totalLaunchedValue = totalLaunched.getAndSet(0);
+        int totalReleasedValue = totalReleased.getAndSet(0);
+        int totalFailedValue = totalFailed.getAndSet(0);
+        int totalExpiredValue = totalExpired.getAndSet(0);
+        int totalRejectedValue = totalRejected.getAndSet(0);
+        int totalRateLimitedValue = totalRateLimited.getAndSet(0);
+        int rateLimitedTenantsValue = rateLimitedTenants.size();
+        int concurrencyLevelValue = concurrencyLevel.get();
+        if (queueSize > 0 || totalAddedValue > 0 || totalLaunchedValue > 0 || totalReleasedValue > 0 ||
+                totalFailedValue > 0 || totalExpiredValue > 0 || totalRejectedValue > 0 || totalRateLimitedValue > 0 || rateLimitedTenantsValue > 0
+                || concurrencyLevelValue > 0) {
+            log.info("Permits queueSize [{}] totalAdded [{}] totalLaunched [{}] totalReleased [{}] totalFailed [{}] totalExpired [{}] totalRejected [{}] " +
+                            "totalRateLimited [{}] totalRateLimitedTenants [{}] currBuffer [{}] ",
+                    queueSize, totalAddedValue, totalLaunchedValue, totalReleasedValue,
+                    totalFailedValue, totalExpiredValue, totalRejectedValue, totalRateLimitedValue, rateLimitedTenantsValue, concurrencyLevelValue);
+        }
 
         rateLimitedTenants.forEach(((tenantId, counter) -> {
             if (printTenantNames) {