Add Method to Extract Undecorated Topic from Datastream Metadata for Accurate SLA Latency Reporting

[harshcum]

Problem & Solution Overview

This PR introduces a new method getUndecoratedTopic() to extract the undecorated topic from the DatastreamRecordMetadata. This method was needed to address an issue where the SLA latency metrics were not being reported correctly due to the presence of topic decorations.

Previously, when extracting the topic name from the metadata, any decorations were included, causing issues with accurate SLA latency reporting. The new method ensures that only the undecorated topic name is used for reporting metrics related to SLA latency, leading to more accurate metrics for throughput and SLA violations.

Changes

• Added getUndecoratedTopic() method: This method extracts the undecorated topic name from the metadata.
• Modified SLA reporting logic: The latency metrics are now correctly reported by using the undecorated topic name.
  This was implemented in the onSendCallback() method where metrics for topics violating the SLA throughput are now based on the undecorated topic name.

Testing

• Validated that the SLA reporting logic now uses the undecorated topic name and calculates the latency metrics correctly.

[kanishkjaiswal2015]

LGTM