Skip to content

Instantly share code, notes, and snippets.

@lmonkiewicz

lmonkiewicz/SendToDlqErrorHandler.java

Last active July 13, 2023 13:57
Show Gist options
  • Save lmonkiewicz/322c132ceabb6d5546361cc5ad80f5ba to your computer and use it in GitHub Desktop.
Save lmonkiewicz/322c132ceabb6d5546361cc5ad80f5ba to your computer and use it in GitHub Desktop.
Download ZIP
Raw
SendToDlqErrorHandler.java
metricOperations.increment(KafkaMetrics.METRIC_NAME,
Tags.of(KafkaTags.topic(topic),
KafkaTags.exception(exception.getClass().getName()),
KafkaTags.processor(context.applicationId())
));
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment