diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorDeduplicationTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorDeduplicationTest.java index eadd0b0ad3c94..20b9f0e8ded5d 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorDeduplicationTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorDeduplicationTest.java @@ -114,6 +114,7 @@ protected void setConfigDefaults(ServiceConfiguration config, String clusterName LocalBookkeeperEnsemble bookkeeperEnsemble, ZookeeperServerTest brokerConfigZk) { super.setConfigDefaults(config, clusterName, bookkeeperEnsemble, brokerConfigZk); // For check whether deduplication snapshot has done. + config.setBrokerDeduplicationSnapshotIntervalSeconds(1); config.setBrokerDeduplicationEntriesInterval(10); config.setReplicationStartAt("earliest"); // To cover more cases, write more than one ledger.