### Question:
KafkaProducerMetricsMonitor implements Runnable { public static String convertSignatureToTag(KafkaProducerConfig key) { return key.getKafkaClusterSignature() .replaceAll("(" + LogConfigUtils.DEFAULT_SERVERSET_DIR + "|discovery|/|prod|\\.)", ""); }  @Override void run(); static String convertSignatureToTag(KafkaProducerConfig key); static final Set<String> PRODUCER_METRICS_ALLOWLIST; }### Answer:
@Test public void testSignatureTagExtractionTLS() { KafkaProducerConfig config = new KafkaProducerConfig("/var/serverset/discovery/kafka_tls/prod", Arrays.asList(), "-1"); assertEquals("kafka_tls", KafkaProducerMetricsMonitor.convertSignatureToTag(config)); }
@Test public void testSignatureTagExtraction() { KafkaProducerConfig config = new KafkaProducerConfig("/var/serverset/discovery/kafka/prod", Arrays.asList(), "-1"); assertEquals("kafka", KafkaProducerMetricsMonitor.convertSignatureToTag(config)); }