Fix duplicate metadata entries in BlobCheckpointStore

kamil-di · kamil-di · commit 8a1afbf2bc08 · 2025-10-02T11:16:08.000+02:00
diff --git a/sdk/eventhubs/azure-messaging-eventhubs-checkpointstore-blob/src/main/java/com/azure/messaging/eventhubs/checkpointstore/blob/BlobCheckpointStore.java b/sdk/eventhubs/azure-messaging-eventhubs-checkpointstore-blob/src/main/java/com/azure/messaging/eventhubs/checkpointstore/blob/BlobCheckpointStore.java
@@ -267,8 +267,6 @@ public Mono<Void> updateCheckpoint(Checkpoint checkpoint) {
         }
         metadata.put(SEQUENCE_NUMBER, sequenceNumber);
         metadata.put(OFFSET, offset);
-        metadata.put(SEQUENCE_NUMBER, sequenceNumber);
-        metadata.put(OFFSET, checkpoint.getOffsetString());
         BlobAsyncClient blobAsyncClient = blobClients.get(blobName);
 
         return blobAsyncClient.exists().flatMap(exists -> {

Original file line number	Diff line number	Diff line change
`@@ -267,8 +267,6 @@ public Mono<Void> updateCheckpoint(Checkpoint checkpoint) {`
`267`	`267`	`}`
`268`	`268`	`metadata.put(SEQUENCE_NUMBER, sequenceNumber);`
`269`	`269`	`metadata.put(OFFSET, offset);`
`270`		`- metadata.put(SEQUENCE_NUMBER, sequenceNumber);`
`271`		`- metadata.put(OFFSET, checkpoint.getOffsetString());`
`272`	`270`	`BlobAsyncClient blobAsyncClient = blobClients.get(blobName);`
`273`	`271`
`274`	`272`	`return blobAsyncClient.exists().flatMap(exists -> {`