Skip to content

Commit 1cffb3a

Browse files
committed
#46752: Fix missing offset assignment logic in checkpoint store
1 parent 5a83cf6 commit 1cffb3a

File tree

1 file changed

+9
-1
lines changed
  • sdk/eventhubs/azure-messaging-eventhubs-checkpointstore-blob/src/main/java/com/azure/messaging/eventhubs/checkpointstore/blob

1 file changed

+9
-1
lines changed

sdk/eventhubs/azure-messaging-eventhubs-checkpointstore-blob/src/main/java/com/azure/messaging/eventhubs/checkpointstore/blob/BlobCheckpointStore.java

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -258,7 +258,15 @@ public Mono<Void> updateCheckpoint(Checkpoint checkpoint) {
258258
Map<String, String> metadata = new HashMap<>();
259259
String sequenceNumber
260260
= checkpoint.getSequenceNumber() == null ? null : String.valueOf(checkpoint.getSequenceNumber());
261-
261+
262+
String offset;
263+
if (checkpoint.getOffsetString() == null || checkpoint.getOffsetString().isEmpty()) {
264+
offset = String.valueOf(checkpoint.getOffset());
265+
} else {
266+
offset = checkpoint.getOffsetString();
267+
}
268+
metadata.put(SEQUENCE_NUMBER, sequenceNumber);
269+
metadata.put(OFFSET, offset);
262270
metadata.put(SEQUENCE_NUMBER, sequenceNumber);
263271
metadata.put(OFFSET, checkpoint.getOffsetString());
264272
BlobAsyncClient blobAsyncClient = blobClients.get(blobName);

0 commit comments

Comments
 (0)