Revert rename

Author: Daniil Zulin

topic/src/test/java/tech/ydb/topic/impl/YdbTopicsIntegrationTest.java

@@ -53,8 +53,9 @@ public class YdbTopicsIntegrationTest {
     @ClassRule
     public final static GrpcTransportRule ydbTransport = new GrpcTransportRule();
 
-    private final static String TEST_TOPIC1 = "integration_test_topic";
-    private final static String TEST_TOPIC2 = "integration_test_other_topic";
+    private final static String TEST_TOPIC = "integration_test_topic";
+    private final static String TEST_OTHER_TOPIC = "integration_test_other_topic";
+
     private final static String TEST_CONSUMER1 = "consumer";
     private final static String TEST_CONSUMER2 = "other_consumer";
 
@@ -70,10 +71,10 @@ public class YdbTopicsIntegrationTest {
 
     @BeforeClass
     public static void initTopic() {
-        logger.info("Create test topic {} ...", TEST_TOPIC1);
+        logger.info("Create test topic {} ...", TEST_TOPIC);
 
         client = TopicClient.newClient(ydbTransport).build();
-        client.createTopic(TEST_TOPIC1, CreateTopicSettings.newBuilder()
+        client.createTopic(TEST_TOPIC, CreateTopicSettings.newBuilder()
                 .addConsumer(Consumer.newBuilder().setName(TEST_CONSUMER1).build())
                 .addConsumer(Consumer.newBuilder().setName(TEST_CONSUMER2).build())
                 .build()
@@ -82,16 +83,16 @@ public static void initTopic() {
 
     @AfterClass
     public static void dropTopic() {
-        logger.info("Drop test topic {} ...", TEST_TOPIC1);
-        Status dropStatus = client.dropTopic(TEST_TOPIC1).join();
+        logger.info("Drop test topic {} ...", TEST_TOPIC);
+        Status dropStatus = client.dropTopic(TEST_TOPIC).join();
         client.close();
         dropStatus.expectSuccess("can't drop test topic");
     }
 
     @Test
     public void step01_writeWithoutDeduplication() throws InterruptedException, ExecutionException, TimeoutException {
         WriterSettings settings = WriterSettings.newBuilder()
-                .setTopicPath(TEST_TOPIC1)
+                .setTopicPath(TEST_TOPIC)
                 .build();
         SyncWriter writer = client.createSyncWriter(settings);
         writer.init();
@@ -111,7 +112,7 @@ public void step01_writeWithoutDeduplication() throws InterruptedException, Exec
     @Test
     public void step02_readHalfWithoutCommit() throws InterruptedException {
         ReaderSettings settings = ReaderSettings.newBuilder()
-                .addTopic(TopicReadSettings.newBuilder().setPath(TEST_TOPIC1).build())
+                .addTopic(TopicReadSettings.newBuilder().setPath(TEST_TOPIC).build())
                 .setConsumerName(TEST_CONSUMER1)
                 .build();
 
@@ -129,7 +130,7 @@ public void step02_readHalfWithoutCommit() throws InterruptedException {
     @Test
     public void step03_readHalfWithCommit() throws InterruptedException {
         ReaderSettings settings = ReaderSettings.newBuilder()
-                .addTopic(TopicReadSettings.newBuilder().setPath(TEST_TOPIC1).build())
+                .addTopic(TopicReadSettings.newBuilder().setPath(TEST_TOPIC).build())
                 .setConsumerName(TEST_CONSUMER1)
                 .build();
 
@@ -148,7 +149,7 @@ public void step03_readHalfWithCommit() throws InterruptedException {
     @Test
     public void step03_readNextHalfWithoutCommit() throws InterruptedException {
         ReaderSettings settings = ReaderSettings.newBuilder()
-                .addTopic(TopicReadSettings.newBuilder().setPath(TEST_TOPIC1).build())
+                .addTopic(TopicReadSettings.newBuilder().setPath(TEST_TOPIC).build())
                 .setConsumerName(TEST_CONSUMER1)
                 .build();
 
@@ -170,7 +171,7 @@ public void step03_readNextHalfWithoutCommit() throws InterruptedException {
     @Test
     public void step04_readNextHalfWithCommit() throws InterruptedException {
         ReaderSettings settings = ReaderSettings.newBuilder()
-                .addTopic(TopicReadSettings.newBuilder().setPath(TEST_TOPIC1).build())
+                .addTopic(TopicReadSettings.newBuilder().setPath(TEST_TOPIC).build())
                 .setConsumerName(TEST_CONSUMER1)
                 .build();
 
@@ -194,7 +195,7 @@ public void step04_readNextHalfWithCommit() throws InterruptedException {
 
     @Test
     public void step05_describeTopic() {
-        TopicDescription description = client.describeTopic(TEST_TOPIC1).join().getValue();
+        TopicDescription description = client.describeTopic(TEST_TOPIC).join().getValue();
 
         Assert.assertNull(description.getTopicStats());
         List<Consumer> consumers = description.getConsumers();
@@ -207,7 +208,7 @@ public void step05_describeTopic() {
     @Test
     public void step06_readAllByAsyncReader() throws InterruptedException {
         ReaderSettings settings = ReaderSettings.newBuilder()
-                .addTopic(TopicReadSettings.newBuilder().setPath(TEST_TOPIC1).build())
+                .addTopic(TopicReadSettings.newBuilder().setPath(TEST_TOPIC).build())
                 .setConsumerName(TEST_CONSUMER2)
                 .build();
 
@@ -246,7 +247,7 @@ public void onMessages(DataReceivedEvent dre) {
 
     @Test
     public void step07_alterTopicWithAutoPartitioning() {
-        client.alterTopic(TEST_TOPIC1, AlterTopicSettings.newBuilder()
+        client.alterTopic(TEST_TOPIC, AlterTopicSettings.newBuilder()
                         .setAlterPartitioningSettings(AlterPartitioningSettings.newBuilder()
                                 .setAutoPartitioningStrategy(AutoPartitioningStrategy.SCALE_UP)
                                 .setMaxActivePartitions(10)
@@ -258,7 +259,7 @@ public void step07_alterTopicWithAutoPartitioning() {
                                 .build())
                 .build()).join().expectSuccess("can't alter the topic");
 
-        TopicDescription description = client.describeTopic(TEST_TOPIC1).join().getValue();
+        TopicDescription description = client.describeTopic(TEST_TOPIC).join().getValue();
 
         PartitioningSettings actualPartitioningSettings = description.getPartitioningSettings();
         PartitioningSettings expectedPartitioningSettings = PartitioningSettings.newBuilder()
@@ -288,13 +289,13 @@ public void step08_createTopicWithAutoPartitioning() {
                         .build())
                 .build();
 
-        CompletableFuture<Status> secondaryTopicCreated = client.createTopic(TEST_TOPIC2, CreateTopicSettings.newBuilder()
+        CompletableFuture<Status> secondaryTopicCreated = client.createTopic(TEST_OTHER_TOPIC, CreateTopicSettings.newBuilder()
                 .setPartitioningSettings(expectedPartitioningSettings)
                 .build());
 
         secondaryTopicCreated.join().expectSuccess("can't create the topic");
 
-        TopicDescription description = client.describeTopic(TEST_TOPIC2).join().getValue();
+        TopicDescription description = client.describeTopic(TEST_OTHER_TOPIC).join().getValue();
 
         Assert.assertEquals(expectedPartitioningSettings, description.getPartitioningSettings());
     }