From 16117af741165b1c038fda4a3c9d99550c2d0bba Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=C2=A8Claude?= <¨claude.warren@aiven.io¨>
Date: Tue, 24 Dec 2024 08:46:58 +0000
Subject: [PATCH] added logging

---
 .../main/java/io/aiven/kafka/connect/common/OffsetManager.java  | 2 ++
 1 file changed, 2 insertions(+)

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
index e4fbf86a..7ad47fd2 100644
--- 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());