gistfile1.txt

        metricOperations.increment(KafkaMetrics.METRIC_NAME,
                Tags.of(KafkaTags.topic(topic),
                        KafkaTags.exception(exception.getClass().getName()),
                        KafkaTags.processor(context.applicationId())
                ));

MetricOperations.java

@RequiredArgsConstructor
@Component
public class MetricOperations {

    private final MeterRegistry meterRegistry;

    public Counter counter(String metricName, Tags tags) {
        return meterRegistry.counter(metricName, tags);
    }

    public void increment(String metricName, Tags tags) {
        counter(metricName, tags).increment();
    }
}