Legacy checkpoint support (#38546)

Azure · Sep 13, 2023 · c8a5165 · c8a5165
1 parent cc54deb
commit c8a5165
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/...hub/Microsoft.Azure.WebJobs.Extensions.EventHubs/src/Listeners/EventHubMetricsProvider.cs b/...hub/Microsoft.Azure.WebJobs.Extensions.EventHubs/src/Listeners/EventHubMetricsProvider.cs
@@ -109,7 +109,8 @@ private EventHubsTriggerMetrics CreateTriggerMetrics(List<PartitionProperties> p
                 // In that case, LastEnqueuedSequenceNumber will be >= 0
 
                 if ((partitionProperties.LastEnqueuedSequenceNumber != -1 && partitionProperties.LastEnqueuedSequenceNumber != (checkpoint?.SequenceNumber ?? -1))
-                    || (checkpoint == null && partitionProperties.LastEnqueuedSequenceNumber >= 0))
+                    || (checkpoint == null && partitionProperties.LastEnqueuedSequenceNumber >= 0)
+                    || (checkpoint != null && checkpoint.Offset == null && partitionProperties.LastEnqueuedSequenceNumber >= 0))
                 {
                     long partitionUnprocessedEventCount = GetUnprocessedEventCount(partitionProperties, checkpoint);
                     totalUnprocessedEventCount += partitionUnprocessedEventCount;
@@ -157,6 +158,12 @@ private static long GetUnprocessedEventCount(PartitionProperties partitionInfo,
                 return 1;
             }
 
+            // Legacy checkpoint support
+            if (checkpoint != null && checkpoint.Offset == null && partitionInfo.LastEnqueuedSequenceNumber >= 0)
+            {
+                return partitionInfo.LastEnqueuedSequenceNumber + 1;
+            }
+
             var startingSequenceNumber = checkpoint?.SequenceNumber switch
             {
                 // There was no checkpoint, use the beginning sequence number - 1, since