fix compile

apache · Aug 18, 2022 · bfd73f3 · bfd73f3
1 parent fd7198b
commit bfd73f3
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 6 deletions.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractReplicator.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractReplicator.java
@@ -81,8 +81,8 @@ public AbstractReplicator(String localCluster, String localTopicName, String rem
         this.producer = null;
         this.producerQueueSize = brokerService.pulsar().getConfiguration().getReplicationProducerQueueSize();
         this.replicatorId = String.format("%s | %s",
-                StringUtils.equals(localTopicName, remoteTopicName) ?
-                        localTopicName : localTopicName + "-->" + remoteTopicName,
+                StringUtils.equals(localTopicName, remoteTopicName) ? localTopicName :
+                        localTopicName + "-->" + remoteTopicName,
                 StringUtils.equals(localCluster, remoteCluster) ? localCluster : localCluster + "-->" + remoteCluster
         );
         this.producerBuilder = replicationClient.newProducer(Schema.AUTO_PRODUCE_BYTES()) //
@@ -95,7 +95,7 @@ public AbstractReplicator(String localCluster, String localTopicName, String rem
         STATE_UPDATER.set(this, State.Stopped);
     }
 
-    abstract protected String getProducerName();
+    protected abstract String getProducerName();
 
     protected abstract void readEntries(org.apache.pulsar.client.api.Producer<byte[]> producer);
 

diff --git a/...er/src/main/java/org/apache/pulsar/broker/service/persistent/GeoPersistentReplicator.java b/...er/src/main/java/org/apache/pulsar/broker/service/persistent/GeoPersistentReplicator.java
@@ -31,8 +31,9 @@
 @Slf4j
 public class GeoPersistentReplicator extends PersistentReplicator {
 
-    public GeoPersistentReplicator(PersistentTopic topic, ManagedCursor cursor, String localCluster, String remoteCluster,
-                                BrokerService brokerService, PulsarClientImpl replicationClient)
+    public GeoPersistentReplicator(PersistentTopic topic, ManagedCursor cursor, String localCluster,
+                                   String remoteCluster, BrokerService brokerService,
+                                   PulsarClientImpl replicationClient)
             throws PulsarServerException {
         super(localCluster, topic, cursor, remoteCluster, topic.getName(), brokerService, replicationClient);
     }

diff --git a/...roker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentReplicator.java b/...roker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentReplicator.java
@@ -271,7 +271,8 @@ public void readEntriesComplete(List<Entry> entries, Object ctx) {
         if (readBatchSize < maxReadBatchSize) {
             int newReadBatchSize = Math.min(readBatchSize * 2, maxReadBatchSize);
             if (log.isDebugEnabled()) {
-                log.debug("[{}] Increasing read batch size from {} to {}", replicatorId, readBatchSize, newReadBatchSize);
+                log.debug("[{}] Increasing read batch size from {} to {}", replicatorId, readBatchSize,
+                        newReadBatchSize);
             }
 
             readBatchSize = newReadBatchSize;