Merge pull request #393 from alex268/topic_fixes

Topic fixes

Author: alex268

topic/src/main/java/tech/ydb/topic/impl/GrpcStreamRetrier.java

@@ -92,6 +92,11 @@ private void tryScheduleReconnect() {
     }
 
     void reconnect() {
+        if (isStopped.get()) {
+            getLogger().info("[{}] {} is already stopped, no need to reconnect", id, getStreamName());
+            return;
+        }
+
         getLogger().info("[{}] {} reconnect #{} started", id, getStreamName(), reconnectCounter.get());
         if (!isReconnecting.compareAndSet(true, false)) {
             getLogger().warn("Couldn't reset reconnect flag. Shouldn't happen");

topic/src/main/java/tech/ydb/topic/impl/TopicClientImpl.java

@@ -89,6 +89,7 @@ private GrpcRequestSettings makeGrpcRequestSettings(BaseRequestSettings settings
     }
 
     @Override
+    @SuppressWarnings("deprecation")
     public CompletableFuture<Status> createTopic(String path, CreateTopicSettings settings) {
         YdbTopic.CreateTopicRequest.Builder requestBuilder = YdbTopic.CreateTopicRequest.newBuilder()
                 .setOperationParams(Operation.buildParams(settings))
@@ -125,6 +126,7 @@ public CompletableFuture<Status> createTopic(String path, CreateTopicSettings se
     }
 
     @Override
+    @SuppressWarnings("deprecation")
     public CompletableFuture<Status> alterTopic(String path, AlterTopicSettings settings) {
         YdbTopic.AlterTopicRequest.Builder requestBuilder = YdbTopic.AlterTopicRequest.newBuilder()
                 .setOperationParams(Operation.buildParams(settings))
@@ -257,6 +259,7 @@ public CompletableFuture<Result<ConsumerDescription>> describeConsumer(
                 .thenApply(result -> result.map(ConsumerDescription::new));
     }
 
+    @SuppressWarnings("deprecation")
     private TopicDescription mapDescribeTopic(YdbTopic.DescribeTopicResult result) {
         if (logger.isTraceEnabled()) {
             logger.trace("Received topic describe response:\n{}", result);