Commit ef43eb4d authored by 王亮's avatar 王亮

fix overflow bug(int).

parent 5ff433f6
...@@ -16,7 +16,7 @@ ...@@ -16,7 +16,7 @@
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<!-- <maven.test.skip>true</maven.test.skip>--> <!-- <maven.test.skip>true</maven.test.skip>-->
<maven.javadoc.skip>true</maven.javadoc.skip> <maven.javadoc.skip>true</maven.javadoc.skip>
<revision>2.6.3.6</revision> <revision>2.6.3.7</revision>
<maven-compiler-plugin.version>3.8.1</maven-compiler-plugin.version> <maven-compiler-plugin.version>3.8.1</maven-compiler-plugin.version>
<maven-source-plugin.version>3.2.1</maven-source-plugin.version> <maven-source-plugin.version>3.2.1</maven-source-plugin.version>
<maven-javadoc-plugin.version>3.3.1</maven-javadoc-plugin.version> <maven-javadoc-plugin.version>3.3.1</maven-javadoc-plugin.version>
......
...@@ -11,7 +11,7 @@ ...@@ -11,7 +11,7 @@
<packaging>pom</packaging> <packaging>pom</packaging>
<properties> <properties>
<revision>2.6.3.6</revision> <revision>2.6.3.7</revision>
<spring-boot.version>2.6.3</spring-boot.version> <spring-boot.version>2.6.3</spring-boot.version>
<spring-cloud.version>2021.0.1</spring-cloud.version> <spring-cloud.version>2021.0.1</spring-cloud.version>
<spring-cloud-alibaba.version>2021.0.1.0</spring-cloud-alibaba.version> <spring-cloud-alibaba.version>2021.0.1.0</spring-cloud-alibaba.version>
......
...@@ -78,7 +78,7 @@ public class KafkaMeterRegistry extends StepMeterRegistry { ...@@ -78,7 +78,7 @@ public class KafkaMeterRegistry extends StepMeterRegistry {
gauge -> writeGauge(gauge.getId(), gauge.value(getBaseTimeUnit())), gauge -> writeGauge(gauge.getId(), gauge.value(getBaseTimeUnit())),
counter -> writeCounter(counter.getId(), counter.count()), this::writeFunctionTimer, counter -> writeCounter(counter.getId(), counter.count()), this::writeFunctionTimer,
this::writeMeter)).forEach(i -> { this::writeMeter)).forEach(i -> {
kafkaProducer.send(new ProducerRecord<>(config.topic(), (int)System.currentTimeMillis()%partition,key, i)); kafkaProducer.send(new ProducerRecord<>(config.topic(), (int)(System.currentTimeMillis()%partition),key, i));
}); });
} }
} }
......
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