screen-manage/src/main/java/com/moral/api/kafka/consumer/KafkaConsumer.java | ●●●●● patch | view | raw | blame | history |
screen-manage/src/main/java/com/moral/api/kafka/consumer/KafkaConsumer.java
@@ -62,7 +62,7 @@ String key = next.getKey(); Object value = next.getValue(); if (key.contains("-Avg")) { newMap.put(key.replaceAll("-Avg", ""), value); newMap.put(key.replaceAll("-Avg", ""), Double.parseDouble(value.toString())); } else { newMap.put(key, value); } @@ -102,7 +102,7 @@ String key = next.getKey(); Object value = next.getValue(); if (key.contains("-Avg")) { newMap.put(key.replaceAll("-Avg", ""), value); newMap.put(key.replaceAll("-Avg", ""), Double.parseDouble(value.toString())); } else { newMap.put(key, value); }