Skip to content

Commit e64cd5e

Browse files
committed
[fix][broker] Update NonPersistentReplicator to include PulsarAdmin in constructor
1 parent cf0da5e commit e64cd5e

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ public NonPersistentReplicator(NonPersistentTopic topic, String localCluster, St
5555
BrokerService brokerService, PulsarClientImpl replicationClient,
5656
PulsarAdmin replicationAdmin) throws PulsarServerException {
5757
super(localCluster, topic, remoteCluster, topic.getName(), topic.getReplicatorPrefix(), brokerService,
58-
replicationClient);
58+
replicationClient, replicationAdmin);
5959
// NonPersistentReplicator does not support limitation so far, so reset pending queue size to the default value.
6060
producerBuilder.maxPendingMessages(1000);
6161
producerBuilder.blockIfQueueFull(false);

0 commit comments

Comments
 (0)