Browse Source

Minor improvements for EDQS

pull/13362/head
ViacheslavKlimov 1 year ago
parent
commit
de855e5236
  1. 2
      common/edqs/src/main/java/org/thingsboard/server/edqs/util/VersionsStore.java
  2. 3
      common/queue/src/main/java/org/thingsboard/server/queue/kafka/TbKafkaConsumerStatsService.java

2
common/edqs/src/main/java/org/thingsboard/server/edqs/util/VersionsStore.java

@ -36,7 +36,7 @@ public class VersionsStore {
isNew.set(true); isNew.set(true);
return version; return version;
} else { } else {
log.info("[{}] Version {} is outdated, the latest is {}", key, version, prevVersion); log.debug("[{}] Version {} is outdated, the latest is {}", key, version, prevVersion);
return prevVersion; return prevVersion;
} }
}); });

3
common/queue/src/main/java/org/thingsboard/server/queue/kafka/TbKafkaConsumerStatsService.java

@ -93,8 +93,7 @@ public class TbKafkaConsumerStatsService {
log.info("[{}] Topic partitions with lag: [{}].", groupId, builder.toString()); log.info("[{}] Topic partitions with lag: [{}].", groupId, builder.toString());
} }
} catch (Exception e) { } catch (Exception e) {
log.warn("[{}] Failed to get consumer group stats. Reason - {}.", groupId, e.getMessage()); log.warn("[{}] Failed to get consumer group stats", groupId, e);
log.trace("Detailed error: ", e);
} }
} }

Loading…
Cancel
Save