PR comments #2

snowflakedb · Jun 3, 2024 · cc2b6f9 · cc2b6f9
1 parent 906e205
commit cc2b6f9
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...in/java/com/snowflake/kafka/connector/internal/streaming/DirectTopicPartitionChannel.java b/...in/java/com/snowflake/kafka/connector/internal/streaming/DirectTopicPartitionChannel.java
@@ -889,6 +889,7 @@ public long getProcessedOffset() {
 
   @Override
   @VisibleForTesting
+  @Deprecated
   public long getLatestConsumerOffset() {
     return 0;
   }