Commit 2d3ba4e9 authored by 王亮's avatar 王亮

fix escape bug.(atom logic issue)

parent 5660fd0b
...@@ -100,7 +100,7 @@ public class KafkaMeterRegistry extends StepMeterRegistry { ...@@ -100,7 +100,7 @@ public class KafkaMeterRegistry extends StepMeterRegistry {
String ip = applicationContext.getEnvironment().getProperty("spring.cloud.client.ip-address"); String ip = applicationContext.getEnvironment().getProperty("spring.cloud.client.ip-address");
tags = tags + (",ip=" + ip); tags = tags + (",ip=" + ip);
return getConventionName(id) + tags + ",metric_type=" + escapeLine(ElementEnum.Measurement, return getConventionName(id) + tags + ",metric_type=" + escapeLine(ElementEnum.TagValue,
metricType) + " " + fields.map( metricType) + " " + fields.map(
Field::toString).collect(joining(",")) + " " + clock.wallTime(); Field::toString).collect(joining(",")) + " " + clock.wallTime();
} }
...@@ -190,10 +190,9 @@ public class KafkaMeterRegistry extends StepMeterRegistry { ...@@ -190,10 +190,9 @@ public class KafkaMeterRegistry extends StepMeterRegistry {
private static String escapeLine(ElementEnum elementEnum, String line) { private static String escapeLine(ElementEnum elementEnum, String line) {
AtomicReference<String> result = new AtomicReference<>(""); AtomicReference<String> result = new AtomicReference<>("");
result.set(line);
Arrays.stream(CharacterEnum.values()).filter(i -> i.getElement().contains(elementEnum)) Arrays.stream(CharacterEnum.values()).filter(i -> i.getElement().contains(elementEnum))
.forEach(i -> { .forEach(i -> result.set(result.get().replace(i.getValue(), i.getElapsedValue())));
result.set(line.replace(i.getValue(), i.getElapsedValue()));
});
return result.get(); return result.get();
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment