Move data.put inside null check in writeOffset method

scwlkq · Feb 20, 2024 · 4831157 · 4831157
1 parent 0e356cb
commit 4831157
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...java/org/apache/eventmesh/openconnect/offsetmgmt/api/storage/OffsetStorageWriterImpl.java b/...java/org/apache/eventmesh/openconnect/offsetmgmt/api/storage/OffsetStorageWriterImpl.java
@@ -57,8 +57,8 @@ public void writeOffset(RecordPartition partition, RecordOffset offset) {
         ConnectorRecordPartition extendRecordPartition = null;
         if (partition != null && partition.getPartition() != null) {
             extendRecordPartition = new ConnectorRecordPartition(connectorName, partition.getPartition());
+            data.put(extendRecordPartition, offset);
         }
-        data.put(extendRecordPartition, offset);
     }
 
     /**