diff --git a/kafka-connect/src/main/java/io/tabular/iceberg/connect/channel/CommitterImpl.java b/kafka-connect/src/main/java/io/tabular/iceberg/connect/channel/CommitterImpl.java
index 10730d99..0174f868 100644
--- a/kafka-connect/src/main/java/io/tabular/iceberg/connect/channel/CommitterImpl.java
+++ b/kafka-connect/src/main/java/io/tabular/iceberg/connect/channel/CommitterImpl.java
@@ -112,8 +112,7 @@ private Map<TopicPartition, Long> fetchStableConsumerOffsets(String groupId) {
     try {
       ListConsumerGroupOffsetsResult response =
           admin()
-              .listConsumerGroupOffsets(
-                  groupId, new ListConsumerGroupOffsetsOptions().requireStable(true));
+              .listConsumerGroupOffsets(groupId);
       return response.partitionsToOffsetAndMetadata().get().entrySet().stream()
           .filter(entry -> context.assignment().contains(entry.getKey()))
           .collect(toMap(Map.Entry::getKey, entry -> entry.getValue().offset()));