update

etl-core/src/main/java/com/tzld/crawler/etl/mq/EtlMQConsumer.java

@@ -123,7 +123,7 @@ public class EtlMQConsumer {
                     param.setMessageId(messageId);
                     String key = String.format(DEDUP_KEY, messageKey);
                     if (!redisUtil.setNx(key, "1", CacheConstant.TWENTY_HOUR_SECOND)) {
-                        metric(MetricTypeEnum.PARAM_INVALID, JSONObject.toJSONString(message), param);
+                        metric(MetricTypeEnum.KEY_DUPLICATED, JSONObject.toJSONString(message), param);
                         log.info("dedup message: {} from topic: {}, group: {} messageId: {} messageKey = {}", message, topic, groupId, messageId, messageKey);
                         continue;
                     }