Skip to content

Commit

Permalink
[NUC-233] Ensure the call to setShardSequenceNumberInPersistency fail…
Browse files Browse the repository at this point in the history
…s for non-existing or non-shard objects.
  • Loading branch information
Alex Toker committed Aug 28, 2024
1 parent f723111 commit b956c1f
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions pkg/dataplane/streamconsumergroup/streamconsumergroup.go
Original file line number Diff line number Diff line change
Expand Up @@ -367,6 +367,7 @@ func (scg *streamConsumerGroup) setShardSequenceNumberInPersistency(shardID int,
Attributes: map[string]interface{}{
scg.getShardCommittedSequenceNumberAttributeName(): sequenceNumber,
},
Condition: "__obj_type == 3",
})
return err
}
Expand Down

0 comments on commit b956c1f

Please sign in to comment.