private void loadTopicOffsetMetric()

in src/main/java/org/apache/rocketmq/exporter/collector/RMQMetricsCollector.java [334:342]

• 9 lines of code
• 1 McCabe index (conditional complexity)

    private void loadTopicOffsetMetric(GaugeMetricFamily family, Map.Entry<ProducerMetric, Double> entry) {
        family.addMetric(
            Arrays.asList(
                entry.getKey().getClusterName(),
                entry.getKey().getBrokerName(),
                entry.getKey().getTopicName()
            ),
            entry.getValue());
    }