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());