diff --git a/topic/src/main/java/tech/ydb/topic/settings/ReaderSettings.java b/topic/src/main/java/tech/ydb/topic/settings/ReaderSettings.java index 40f3aed5..e523ef92 100644 --- a/topic/src/main/java/tech/ydb/topic/settings/ReaderSettings.java +++ b/topic/src/main/java/tech/ydb/topic/settings/ReaderSettings.java @@ -1,7 +1,5 @@ package tech.ydb.topic.settings; -import java.time.Duration; -import java.time.Instant; import java.util.ArrayList; import java.util.List; import java.util.concurrent.Executor; @@ -20,9 +18,6 @@ public class ReaderSettings { private final String readerName; private final List topics; private final long maxMemoryUsageBytes; - private final Duration maxLag; - private final Instant readFrom; - private final boolean decompress; private final Executor decompressionExecutor; private ReaderSettings(Builder builder) { @@ -30,9 +25,6 @@ private ReaderSettings(Builder builder) { this.readerName = builder.readerName; this.topics = ImmutableList.copyOf(builder.topics); this.maxMemoryUsageBytes = builder.maxMemoryUsageBytes; - this.maxLag = builder.maxLag; - this.readFrom = builder.readFrom; - this.decompress = builder.decompress; this.decompressionExecutor = builder.decompressionExecutor; } @@ -53,18 +45,6 @@ public long getMaxMemoryUsageBytes() { return maxMemoryUsageBytes; } - public Duration getMaxLag() { - return maxLag; - } - - public Instant getReadFrom() { - return readFrom; - } - - public boolean isDecompress() { - return decompress; - } - public Executor getDecompressionExecutor() { return decompressionExecutor; } @@ -82,9 +62,6 @@ public static class Builder { private String readerName = null; private List topics = new ArrayList<>(); private long maxMemoryUsageBytes = MAX_MEMORY_USAGE_BYTES_DEFAULT; - private Duration maxLag = null; - private Instant readFrom = null; - private boolean decompress = true; private Executor decompressionExecutor = null; public Builder setConsumerName(String consumerName) { @@ -126,26 +103,6 @@ public Builder setMaxMemoryUsageBytes(long maxMemoryUsageBytes) { return this; } - public Builder setMaxLag(Duration maxLag) { - this.maxLag = maxLag; - return this; - } - - public Builder setReadFrom(Instant readFrom) { - this.readFrom = readFrom; - return this; - } - - /** - * Set whether messages should be decompressed. - * @param decompress whether messages should be decompressed. true by default - * @return settings builder - */ - public Builder setDecompress(boolean decompress) { - this.decompress = decompress; - return this; - } - /** * Set executor for decompression tasks. * If not set, default executor will be used.