checkstyle

Author: poorbarcode

pulsar-broker/src/main/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentReplicator.java

@@ -55,7 +55,7 @@ public NonPersistentReplicator(NonPersistentTopic topic, String localCluster, St
                                    BrokerService brokerService, PulsarClientImpl replicationClient,
                                    PulsarAdmin replicationAdmin) throws PulsarServerException {
         super(localCluster, topic, remoteCluster, topic.getName(), topic.getReplicatorPrefix(), brokerService,
-                replicationClient);
+                replicationClient, replicationAdmin);
         // NonPersistentReplicator does not support limitation so far, so reset pending queue size to the default value.
         producerBuilder.maxPendingMessages(1000);
         producerBuilder.blockIfQueueFull(false);

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

@@ -1902,7 +1902,7 @@ public void testReplicatorCreateTopic(boolean isPartitioned) throws Exception {
         Awaitility.await().untilAsserted(() -> {
             if (isPartitioned){
                 assertThat(admin2.topics().getPartitionedTopicList(ns)).contains(tp);
-            }else {
+            } else {
                 assertThat(admin2.topics().getList(ns)).contains(tp);
             }
         });