addressed comments

Author: majisourav99

clients/da-vinci-client/src/main/java/com/linkedin/davinci/StoreBackend.java

@@ -140,36 +140,12 @@ public CompletableFuture<Void> subscribe(ComplementSet<Integer> partitions) {
     return subscribe(partitions, Optional.empty(), null);
   }
 
-  // public CompletableFuture<Void> seekToTimestamps(Long allPartitionTimestamp, Optional<Version> storeVersion) {
-  // return subscribe(
-  // ComplementSet.universalSet(),
-  // storeVersion, null);
-  // }
-
   public CompletableFuture<Void> seekToCheckpoint(
       DaVinciSeekCheckpointInfo checkpointInfo,
       Optional<Version> storeVersion) {
     return subscribe(checkpointInfo.getPartitions(), storeVersion, checkpointInfo);
   }
 
-  // public CompletableFuture<Void> seekToTail(Optional<Version> storeVersion) {
-  // return subscribe(ComplementSet.universalSet(), storeVersion, null);
-  // }
-
-  // public CompletableFuture<Void> seekToCheckPoints(
-  // Map<Integer, PubSubPosition> checkpoints,
-  // Optional<Version> storeVersion) {
-  // return subscribe(
-  // ComplementSet.wrap(checkpoints.keySet()),
-  // storeVersion, null);
-  // }
-
-  // public CompletableFuture<Void> seekToTimestamps(Map<Integer, Long> timestamps, Optional<Version> storeVersion) {
-  // return subscribe(
-  // ComplementSet.wrap(timestamps.keySet()),
-  // storeVersion, null);
-  // }
-
   private Version getCurrentVersion() {
     return backend.getVeniceCurrentVersion(storeName);
   }

clients/da-vinci-client/src/main/java/com/linkedin/davinci/consumer/VeniceChangelogConsumerDaVinciRecordTransformerImpl.java

@@ -318,7 +318,7 @@ public CompletableFuture<Void> seekToBeginningOfPush() {
   }
 
   public CompletableFuture<Void> seekToEndOfPush(Set<Integer> partitions) {
-    return daVinciClient.seekToTail(partitions);
+    throw new VeniceClientException("seekToEndOfPush will not be supported");
   }
 
   public CompletableFuture<Void> seekToEndOfPush() {

clients/da-vinci-client/src/main/java/com/linkedin/davinci/kafka/consumer/StoreIngestionTask.java

@@ -2300,7 +2300,10 @@ protected void processCommonConsumerAction(ConsumerAction consumerAction) throws
 
         // Subscribe to local version topic.
         PubSubPosition subscribePosition;
-        if (consumerAction.getPubSubPosition() != null && recordTransformer != null) {
+        if (consumerAction.getPubSubPosition() != null) {
+          if (recordTransformer == null) {
+            throw new VeniceException("seekToCheckpoint will not be supported for non-transformed client");
+          }
           skipValidationForSeekableClientEnabled = true;
           subscribePosition = consumerAction.getPubSubPosition();
           LOGGER.info("Subscribed to user given partition: {} position: {}", topicPartition, subscribePosition);