addressed comments

majisourav99 · majisourav99 · commit c29260d29bf8 · 2025-11-25T21:19:09.000-08:00
diff --git a/clients/da-vinci-client/src/main/java/com/linkedin/davinci/consumer/VeniceChangelogConsumerDaVinciRecordTransformerImpl.java b/clients/da-vinci-client/src/main/java/com/linkedin/davinci/consumer/VeniceChangelogConsumerDaVinciRecordTransformerImpl.java
@@ -441,6 +441,9 @@ public Collection<PubSubMessage<K, ChangeEvent<V>, VeniceChangeCoordinate>> poll
 
   @Override
   public boolean isCaughtUp() {
+    if (!changelogClientConfig.isStateful()) {
+      throw new VeniceClientException("isCaughtUp is not supported for non-stateful changelog consumer");
+    }
     return isCaughtUp.get();
   }
 

Original file line number	Diff line number	Diff line change
`@@ -441,6 +441,9 @@ public Collection<PubSubMessage<K, ChangeEvent<V>, VeniceChangeCoordinate>> poll`
`441`	`441`
`442`	`442`	`@Override`
`443`	`443`	`public boolean isCaughtUp() {`
	`444`	`+ if (!changelogClientConfig.isStateful()) {`
	`445`	`+ throw new VeniceClientException("isCaughtUp is not supported for non-stateful changelog consumer");`
	`446`	`+ }`
`444`	`447`	`return isCaughtUp.get();`
`445`	`448`	`}`
`446`	`449`