|
| 1 | +package org.apache.pulsar.tests.integration.backwardscompatibility; |
| 2 | + |
| 3 | +import java.util.HashMap; |
| 4 | +import java.util.Map; |
| 5 | +import java.util.function.Supplier; |
| 6 | +import org.apache.pulsar.tests.integration.containers.BrokerContainer; |
| 7 | +import org.apache.pulsar.tests.integration.containers.PulsarContainer; |
| 8 | +import org.apache.pulsar.tests.integration.offload.TestBaseOffload; |
| 9 | +import org.testng.annotations.Test; |
| 10 | + |
| 11 | +public class ClientOffloadTest3_0 extends TestBaseOffload { |
| 12 | + @Override |
| 13 | + protected Map<String, String> getEnv() { |
| 14 | + Map<String, String> result = new HashMap<>(); |
| 15 | + result.put("managedLedgerMaxEntriesPerLedger", String.valueOf(getNumEntriesPerLedger())); |
| 16 | + result.put("managedLedgerMinLedgerRolloverTimeMinutes", "0"); |
| 17 | + result.put("managedLedgerOffloadDriver", "filesystem"); |
| 18 | + result.put("fileSystemURI", "file:///tmp"); |
| 19 | + |
| 20 | + return result; |
| 21 | + } |
| 22 | + |
| 23 | + @Override |
| 24 | + protected void beforeStartCluster() throws Exception { |
| 25 | + super.beforeStartCluster(); |
| 26 | + for (BrokerContainer brokerContainer : pulsarCluster.getBrokers()) { |
| 27 | + brokerContainer.setDockerImageName(PulsarContainer.PULSAR_3_0_IMAGE_NAME); |
| 28 | + } |
| 29 | + } |
| 30 | + |
| 31 | + @Test(dataProvider = "ServiceAndAdminUrls") |
| 32 | + public void testPublishOffloadAndConsumeDeletionLag(Supplier<String> serviceUrl, Supplier<String> adminUrl) |
| 33 | + throws Exception { |
| 34 | + super.testPublishOffloadAndConsumeDeletionLag(serviceUrl.get(), adminUrl.get()); |
| 35 | + } |
| 36 | +} |
0 commit comments