Add comment mentioning experimental feature and improve error message

ydb-platform · Jan 9, 2024 · ff0a42e · ff0a42e
1 parent ace33b8
commit ff0a42e
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/topic/src/main/java/tech/ydb/topic/settings/ReaderSettings.java b/topic/src/main/java/tech/ydb/topic/settings/ReaderSettings.java
@@ -92,6 +92,11 @@ public Builder setConsumerName(String consumerName) {
             return this;
         }
 
+        /**
+         * Experimental feature. Interface may change in future
+         * Explicitly require reading without a consumer. Reading progress will not be saved on server this way.
+         * @return settings builder
+         */
         public Builder withoutConsumer() {
             this.readWithoutConsumer = true;
             return this;
@@ -152,7 +157,8 @@ public Builder setDecompressionExecutor(Executor decompressionExecutor) {
         public ReaderSettings build() {
             if (consumerName == null) {
                 if (!readWithoutConsumer) {
-                    throw new IllegalArgumentException("Missing consumer name for read settings");
+                    throw new IllegalArgumentException("Missing consumer name for read settings. " +
+                            "Use withoutConsumer option explicitly if you want to read without a consumer");
                 }
             } else {
                 if (readWithoutConsumer) {