Guest User

Untitled

a guest
Jan 24th, 2019
84
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.65 KB | None | 0 0
  1. public class EventStreamBacklogTracing
  2. {
  3. public static void LogSequenceDifference(EventData message, PartitionContext context)
  4. {
  5. var messageSequence = message.SystemProperties.SequenceNumber;
  6. var lastEnqueuedSequence = context.RuntimeInformation.LastSequenceNumber;
  7. var sequenceDifference = lastEnqueuedSequence - messageSequence;
  8.  
  9. var client = new TelemetryClient();
  10.  
  11. var metricData = client.GetMetric("PartitionSequenceDifference", "PartitionId", "ConsumerGroupName", "EventHubPath");
  12.  
  13. metricData.TrackValue(sequenceDifference, context.PartitionId, context.ConsumerGroupName, context.EventHubPath);
  14. }
  15. }
Add Comment
Please, Sign In to add comment