unit test env,for adding NAMESPACE scope logic.

qg-micrometer-register-kafka-starter/src/main/java/cn/quantgroup/ext/micrometer/register/kafka/KafkaMeterRegistry.java

@@ -23,6 +23,7 @@ import java.util.stream.Stream;
 import org.apache.kafka.clients.producer.KafkaProducer;
 import org.apache.kafka.clients.producer.ProducerConfig;
 import org.apache.kafka.clients.producer.ProducerRecord;
+import org.springframework.util.ObjectUtils;
 
 public class KafkaMeterRegistry extends StepMeterRegistry {
 
@@ -31,10 +32,18 @@ public class KafkaMeterRegistry extends StepMeterRegistry {
   private final KafkaConfig config;
   private KafkaProducer<String, String> kafkaProducer;
 
+  private final String key;
+
 
   public KafkaMeterRegistry(KafkaConfig config, Clock clock) {
     super(config, clock);
     this.config = config;
+    if (ObjectUtils.isEmpty(System.getProperty("NAMESPACE"))) {
+      key = "default";
+    } else {
+      key = System.getProperty("NAMESPACE");
+    }
+
     Properties properties = new Properties();
     properties.setProperty(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, config.services());
     properties.setProperty(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,
@@ -66,7 +75,7 @@ public class KafkaMeterRegistry extends StepMeterRegistry {
               counter -> writeCounter(counter.getId(), counter.count()),
               this::writeFunctionTimer,
               this::writeMeter)).forEach(i -> {
-            kafkaProducer.send(new ProducerRecord<>(config.topic(), i));
+            kafkaProducer.send(new ProducerRecord<>(config.topic(), key,i));
           });
     }
   }