@Test public void testSignatureTagExtractionTLS() { KafkaProducerConfig config = new KafkaProducerConfig("/var/serverset/discovery/kafka_tls/prod", Arrays.asList(), "-1"); assertEquals("kafka_tls", KafkaProducerMetricsMonitor.convertSignatureToTag(config)); }
public static String convertSignatureToTag(KafkaProducerConfig key) { return key.getKafkaClusterSignature() .replaceAll("(" + LogConfigUtils.DEFAULT_SERVERSET_DIR + "|discovery|/|prod|\\.)", ""); }
KafkaProducerMetricsMonitor implements Runnable { public static String convertSignatureToTag(KafkaProducerConfig key) { return key.getKafkaClusterSignature() .replaceAll("(" + LogConfigUtils.DEFAULT_SERVERSET_DIR + "|discovery|/|prod|\\.)", ""); } }
KafkaProducerMetricsMonitor implements Runnable { public static String convertSignatureToTag(KafkaProducerConfig key) { return key.getKafkaClusterSignature() .replaceAll("(" + LogConfigUtils.DEFAULT_SERVERSET_DIR + "|discovery|/|prod|\\.)", ""); }  }
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); }
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; }