added removing entry from OffsetManager

Aiven-Open · Dec 24, 2024 · 2db3a30 · 2db3a30
1 parent 8d14e7c
commit 2db3a30
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/commons/src/main/java/io/aiven/kafka/connect/common/OffsetManager.java b/commons/src/main/java/io/aiven/kafka/connect/common/OffsetManager.java
@@ -110,9 +110,11 @@ public void updateCurrentOffsets(final E entry) {
     }
 
     /**
-     * Removes the specified entry from the in memory table.  Does not impact the records stored in the
+     * Removes the specified entry from the in memory table. Does not impact the records stored in the
      * {@link SourceTaskContext}.
-     * @param key the key for the entry to remove.
+     *
+     * @param key
+     *            the key for the entry to remove.
      */
     public void remove(final OffsetManagerKey key) {
         LOGGER.info("Removing: {}", key.getPartitionMap());

diff --git a/...-connector/src/main/java/io/aiven/kafka/connect/s3/source/utils/S3OffsetManagerEntry.java b/...-connector/src/main/java/io/aiven/kafka/connect/s3/source/utils/S3OffsetManagerEntry.java
@@ -187,7 +187,6 @@ public Map<String, Object> getProperties() {
         result.put(RECORD_COUNT, recordCount);
         return result;
     }
-
     /**
      * Returns the OffsetManagerKey for this Entry.
      *
-Original file line number
+Diff line change
@@ Expand Up / @@ -187,7 +187,6 @@ public Map<String, Object> getProperties() { @@
             result.put(RECORD_COUNT, recordCount);
             return result;
         }
         /**
          * Returns the OffsetManagerKey for this Entry.
          *
@@ Expand Down @@