debugId -> logPrefix

Author: Igor Melnichenko

topic/src/main/java/tech/ydb/topic/read/impl/ReaderImpl.java

@@ -55,7 +55,7 @@ public abstract class ReaderImpl extends GrpcStreamRetrier {
     private final String consumerName;
 
     public ReaderImpl(TopicRpc topicRpc, ReaderSettings settings) {
-        super(settings.getDebugId(), topicRpc.getScheduler(), settings.getErrorsHandler());
+        super(settings.getLogPrefix(), topicRpc.getScheduler(), settings.getErrorsHandler());
         this.topicRpc = topicRpc;
         this.settings = settings;
         this.session = new ReadSessionImpl();

topic/src/main/java/tech/ydb/topic/settings/ReaderSettings.java

@@ -17,7 +17,7 @@
 public class ReaderSettings {
     private static final long MAX_MEMORY_USAGE_BYTES_DEFAULT = 100 * 1024 * 1024; // 100 MB
 
-    private final String debugId;
+    private final String logPrefix;
     private final String consumerName;
     private final String readerName;
     private final List<TopicReadSettings> topics;
@@ -26,7 +26,7 @@ public class ReaderSettings {
     private final BiConsumer<Status, Throwable> errorsHandler;
 
     private ReaderSettings(Builder builder) {
-        this.debugId = builder.debugId;
+        this.logPrefix = builder.logPrefix;
         this.consumerName = builder.consumerName;
         this.readerName = builder.readerName;
         this.topics = ImmutableList.copyOf(builder.topics);
@@ -35,8 +35,8 @@ private ReaderSettings(Builder builder) {
         this.errorsHandler = builder.errorsHandler;
     }
 
-    public String getDebugId() {
-        return debugId;
+    public String getLogPrefix() {
+        return logPrefix;
     }
 
     public String getConsumerName() {
@@ -72,7 +72,7 @@ public static Builder newBuilder() {
      * BUILDER
      */
     public static class Builder {
-        private String debugId = null;
+        private String logPrefix = null;
         private String consumerName = null;
         private boolean readWithoutConsumer = false;
         private String readerName = null;
@@ -82,15 +82,15 @@ public static class Builder {
         private BiConsumer<Status, Throwable> errorsHandler = null;
 
         /**
-         * Sets an ID of a reader to be used for logging, tracing, etc. If is {@code null}, an autogenerated value will
-         * be used.
+         * Sets a prefix to be used in log messages of a reader. If is {@code null}, an autogenerated value will be
+         * used.
          *
-         * @param debugId the ID
+         * @param logPrefix the prefix
          *
          * @return this builder
          */
-        public Builder setDebugId(String debugId) {
-            this.debugId = debugId;
+        public Builder setLogPrefix(String logPrefix) {
+            this.logPrefix = logPrefix;
             return this;
         }
 

topic/src/main/java/tech/ydb/topic/settings/WriterSettings.java

@@ -12,7 +12,7 @@ public class WriterSettings {
     private static final long MAX_MEMORY_USAGE_BYTES_DEFAULT = 20 * 1024 * 1024; // 20 MB
     private static final int MAX_IN_FLIGHT_COUNT_DEFAULT = 100000;
 
-    private final String debugId;
+    private final String logPrefix;
     private final String topicPath;
     private final String producerId;
     private final String messageGroupId;
@@ -23,7 +23,7 @@ public class WriterSettings {
     private final BiConsumer<Status, Throwable> errorsHandler;
 
     private WriterSettings(Builder builder) {
-        this.debugId = builder.debugId;
+        this.logPrefix = builder.logPrefix;
         this.topicPath = builder.topicPath;
         this.producerId = builder.producerId;
         this.messageGroupId = builder.messageGroupId;
@@ -38,8 +38,8 @@ public static Builder newBuilder() {
         return new Builder();
     }
 
-    public String getDebugId() {
-        return debugId;
+    public String getLogPrefix() {
+        return logPrefix;
     }
 
     public String getTopicPath() {
@@ -78,7 +78,7 @@ public int getMaxSendBufferMessagesCount() {
      * BUILDER
      */
     public static class Builder {
-        private String debugId = null;
+        private String logPrefix = null;
         private String topicPath = null;
         private String producerId = null;
         private String messageGroupId = null;
@@ -89,15 +89,15 @@ public static class Builder {
         private BiConsumer<Status, Throwable> errorsHandler = null;
 
         /**
-         * Sets an ID of a writer to be used for logging, tracing, etc. If is {@code null}, an autogenerated value will
-         * be used.
+         * Sets a prefix to be used in log messages of a writer. If is {@code null}, an autogenerated value will be
+         * used.
          *
-         * @param debugId the ID
+         * @param logPrefix the prefix
          *
          * @return this builder
          */
-        public Builder setDebugId(String debugId) {
-            this.debugId = debugId;
+        public Builder setLogPrefix(String logPrefix) {
+            this.logPrefix = logPrefix;
             return this;
         }
 

topic/src/main/java/tech/ydb/topic/write/impl/WriterImpl.java

@@ -66,7 +66,7 @@ public abstract class WriterImpl extends GrpcStreamRetrier {
     private CompletableFuture<WriteAck> lastAcceptedMessageFuture;
 
     public WriterImpl(TopicRpc topicRpc, WriterSettings settings, Executor compressionExecutor) {
-        super(settings.getDebugId(), topicRpc.getScheduler(), settings.getErrorsHandler());
+        super(settings.getLogPrefix(), topicRpc.getScheduler(), settings.getErrorsHandler());
         this.topicRpc = topicRpc;
         this.settings = settings;
         this.session = new WriteSessionImpl();