🤖 [server][da-vinci] Exclude remote VTs from Global RT DIV consumed bytes tra

cking

When isGlobalRtDivEnabled, consumedBytesSinceLastSync should only track
local version topic (keyed by VT name) and real-time topics (keyed by
broker URL). Remote version topics are excluded from the map entirely.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: KaiSernLim

clients/da-vinci-client/src/main/java/com/linkedin/davinci/kafka/consumer/StoreIngestionTask.java

@@ -1493,10 +1493,13 @@ protected void produceToStoreBufferServiceOrKafka(
           elapsedTimeForPuttingIntoQueue);
       totalBytesRead += recordSize;
       if (isGlobalRtDivEnabled()) {
-        // Key by version topic name when consuming from VT, else by RT broker URL
+        // Key by version topic name when consuming from local VT, by RT broker URL when consuming from RT.
+        // Remote VTs are excluded from tracking.
         PubSubTopic topic = topicPartition.getPubSubTopic();
-        String consumedBytesKey = versionTopic.equals(topic) ? versionTopic.getName() : kafkaUrl;
-        consumedBytesSinceLastSync.compute(consumedBytesKey, (k, v) -> (v == null) ? recordSize : v + recordSize);
+        if (versionTopic.equals(topic) || topic.isRealTime()) {
+          String consumedBytesKey = versionTopic.equals(topic) ? versionTopic.getName() : kafkaUrl;
+          consumedBytesSinceLastSync.compute(consumedBytesKey, (k, v) -> (v == null) ? recordSize : v + recordSize);
+        }
       }
     }