added logging

Aiven-Open · Dec 24, 2024 · 16117af · 16117af
1 parent a67f7cb
commit 16117af
Showing 1 changed file with 2 additions and 0 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
@@ -77,6 +77,7 @@ protected OffsetManager(final SourceTaskContext context,
      * @return the entry.
      */
     public Optional<E> getEntry(final OffsetManagerKey key, final Function<Map<String, Object>, E> creator) {
+        LOGGER.info("getEntry: {}", key.getPartitionMap());
         final Map<String, Object> data = offsets.compute(key.getPartitionMap(), (k, v) -> {
             if (v == null) {
                 final Map<String, Object> kafkaData = context.offsetStorageReader().offset(key.getPartitionMap());
@@ -97,6 +98,7 @@ public Optional<E> getEntry(final OffsetManagerKey key, final Function<Map<Strin
      *            the entry to update.
      */
     public void updateCurrentOffsets(final E entry) {
+        LOGGER.debug("updating current offsets: {}", entry.getManagerKey().getPartitionMap());
         offsets.compute(entry.getManagerKey().getPartitionMap(), (k, v) -> {
             if (v == null) {
                 return new HashMap<>(entry.getProperties());