fix checkstyle error

Author: zhouyifan279

pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java

@@ -765,11 +765,11 @@ public CompletableFuture<Optional<Long>> addProducer(Producer producer,
         return brokerService.checkTopicNsOwnership(getName())
                 .thenCompose(__ ->
                         incrementTopicEpochIfNeeded(producer, producerQueuedFuture))
-                .thenCompose(producerEpoch -> 
+                .thenCompose(producerEpoch ->
                         internalAddProducer(producer).thenApply(ignore -> {
                             USAGE_COUNT_UPDATER.incrementAndGet(this);
                             if (log.isDebugEnabled()) {
-                                log.debug("[{}] [{}] Added producer -- count: {}", topic, producer.getProducerName(), 
+                                log.debug("[{}] [{}] Added producer -- count: {}", topic, producer.getProducerName(),
                                         USAGE_COUNT_UPDATER.get(this));
                             }
                             return producerEpoch;
@@ -963,7 +963,7 @@ protected CompletableFuture<Void> internalAddProducer(Producer producer) {
                 log.warn("[{}] Attempting to add producer to a terminated topic", topic);
                 throw new TopicTerminatedException("Topic was already terminated");
             }
-            
+
             if (isSameAddressProducersExceeded(producer)) {
                 log.warn("[{}] Attempting to add producer to topic which reached max same address producers limit",
                         topic);

pulsar-broker/src/test/java/org/apache/pulsar/broker/service/AbstractTopicTest.java

@@ -26,8 +26,8 @@
 import static org.testng.Assert.assertEquals;
 import static org.testng.Assert.assertNotNull;
 import static org.testng.Assert.fail;
-import com.google.common.collect.ImmutableMap;
 import io.netty.channel.embedded.EmbeddedChannel;
+import java.util.Map;
 import java.util.Optional;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.CompletionException;
@@ -77,7 +77,7 @@ private Supplier<Pair<AbstractTopic, AbstractSubscription>> createProvider(
             }
             Topic topic = spy(topicOpt.get());
             AbstractSubscription subscription = mock(subscriptionClass);
-            doReturn(ImmutableMap.of("subscription", subscription))
+            doReturn(Map.of("subscription", subscription))
                     .when(topic).getSubscriptions();
             return Pair.of((AbstractTopic) topic, subscription);
         };
@@ -127,7 +127,7 @@ public void testOverwriteOldProducerAfterTopicClosed(
 
         // Add old producer
         topic.addProducer(oldProducer, new CompletableFuture<>()).join();
-        
+
         CountDownLatch oldCnxCheckInvokedLatch = new CountDownLatch(1);
         CountDownLatch oldCnxCheckStartLatch = new CountDownLatch(1);
         doAnswer(invocation -> {
@@ -151,14 +151,14 @@ public void testOverwriteOldProducerAfterTopicClosed(
 
         // Wait until new producer entered `AbstractTopic#tryOverwriteOldProducer`
         oldCnxCheckInvokedLatch.await();
-        
+
         topic.close(true);
         // Run pending tasks to remove old producer from topic.
         ((EmbeddedChannel) oldCnx.ctx().channel()).runPendingTasks();
-        
+
         // Unblock ServerCnx#checkConnectionLiveness to resume `AbstractTopic#tryOverwriteOldProducer`
         oldCnxCheckStartLatch.countDown();
-        
+
         // As topic is fenced, adding new producer should fail.
         try {
             producerEpoch.join();