You can use the /openintegration/v1.0/dlq/metrics endpoint to fetch EPS DLQ metric counters.

Request:

• Method: GET
• Endpoint:

  https://<OI Host>:<OI
          Port>/openintegration/v1.0/dlq/metrics

• Description: This API fetches aggregate EPS metric counters from the metrics cache.
• Supported query parameters:
  • sourceTopic: Filters metrics for a source topic. This parameter is optional.
  • dlqTopic: Accepted by the API, but the current implementation filters by sourceTopic.

Response:

The response includes the following fields:

Field	Description
successfulProcessing	Count of successfully processed source records captured through EPS metrics.
retriedRecords	Count of records that entered retry handling.
dlqWrites	Count of records written to DLQ through EPS metrics.

Use the sourceTopic query parameter to filter metrics for a source topic.

Note: While processing is active, metrics and /dlq/messages can show data from slightly different points in time because they are read through different Kafka-backed paths.

The request can return the following response status codes:

• 200: Returns EPS metric counters.
• 503: The metrics cache is initializing.

Examples:

1. Sample Request:

   GET https://<OI Host>:<OI Port>/openintegration/v1.0/dlq/metrics

   Response:

   {
     "successfulProcessing": 12,
     "retriedRecords": 4,
     "dlqWrites": 2
   }
   

   Response fields:

   • successfulProcessing: Count of successfully processed source records captured through EPS metrics.
   • retriedRecords: Count of records that entered retry handling.
   • dlqWrites: Count of records written to DLQ through EPS metrics.
   Note: While processing is active, metrics and /dlq/messages can show data from slightly different points in time because they are read through different Kafka-backed paths.