rseetham opened a new pull request, #18509: URL: https://github.com/apache/pinot/pull/18509
Include the Kafka topic name as part of the ingestion delay gauge metric name so that operators can distinguish metrics by topic when a table has multiple upstream streams. - Add `setOrUpdatePartitionTopicGauge` / `removePartitionTopicGauge` to AbstractMetrics, composing the metric name as <gauge>.<table>.<partition>.<topic>. - Update IngestionDelayTracker.createMetrics / removeMetrics to use the new topic-aware APIs, looking up the topic name from the StreamConfig. - Rename RealtimeTableDataManager.getHostedPartitionsGroupIds → getHostedConsumingPartitionsGroupIds to clarify that only CONSUMING segments are returned. - Add unit tests in AbstractMetricsTest and IngestionDelayTrackerTest covering the new APIs and verifying the topic name appears in the metric name. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
