|
@@ -89,7 +89,7 @@ public class MonitorDataClient implements Runnable {
|
|
|
String ip = invokeContext.get(MonitorDataConstants.INVOKE_CLIENT_IP).toString();
|
|
|
|
|
|
if (data instanceof ApplicationData) {
|
|
|
- ApplicationData applicationData = (ApplicationData) data;
|
|
|
+ ApplicationData applicationData = (ApplicationData)data;
|
|
|
if (applicationData.getApplicationName() == null) {
|
|
|
applicationData.setApplicationName(applicationName);
|
|
|
}
|
|
@@ -157,7 +157,9 @@ public class MonitorDataClient implements Runnable {
|
|
|
|
|
|
// 当未消费数量超过1半的时候,说明消费已经跟不上了。这时候尝试开始加速消费。
|
|
|
if (size >= threshold) {
|
|
|
- logger.warn("开启加速消费 当前数量:" + size);
|
|
|
+ if (size % 1000 == 0) {
|
|
|
+ logger.warn("开启加速消费 当前数量:" + size);
|
|
|
+ }
|
|
|
// 加速消费,按照当前总数10%开始发送,尽可能不占用系统资源。
|
|
|
speedConsumer(rate);
|
|
|
}
|