|
36 | 36 | import java.lang.reflect.Field;
|
37 | 37 | import java.lang.reflect.Method;
|
38 | 38 | import java.time.Duration;
|
39 |
| -import java.util.ArrayList; |
40 | 39 | import java.util.Arrays;
|
41 |
| -import java.util.Collection; |
42 | 40 | import java.util.Collections;
|
43 | 41 | import java.util.HashSet;
|
44 |
| -import java.util.LinkedHashSet; |
45 | 42 | import java.util.List;
|
46 | 43 | import java.util.Optional;
|
47 | 44 | import java.util.Set;
|
|
63 | 60 | import lombok.extern.slf4j.Slf4j;
|
64 | 61 | import org.apache.bookkeeper.mledger.AsyncCallbacks;
|
65 | 62 | import org.apache.bookkeeper.mledger.ManagedLedgerException;
|
66 |
| -import org.apache.bookkeeper.mledger.Position; |
67 | 63 | import org.apache.bookkeeper.mledger.impl.ManagedCursorImpl;
|
68 | 64 | import org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl;
|
69 |
| -import org.apache.bookkeeper.mledger.impl.PositionImpl; |
70 | 65 | import org.apache.pulsar.broker.BrokerTestUtil;
|
71 | 66 | import org.apache.pulsar.broker.resources.ClusterResources;
|
72 | 67 | import org.apache.pulsar.broker.service.persistent.GeoPersistentReplicator;
|
|
81 | 76 | import org.apache.pulsar.client.api.ProducerBuilder;
|
82 | 77 | import org.apache.pulsar.client.api.PulsarClient;
|
83 | 78 | import org.apache.pulsar.client.api.Schema;
|
84 |
| -import org.apache.pulsar.client.api.schema.GenericRecord; |
85 | 79 | import org.apache.pulsar.client.impl.ProducerBuilderImpl;
|
86 | 80 | import org.apache.pulsar.client.impl.ProducerImpl;
|
87 | 81 | import org.apache.pulsar.client.impl.PulsarClientImpl;
|
|
92 | 86 | import org.apache.pulsar.common.policies.data.ClusterData;
|
93 | 87 | import org.apache.pulsar.common.policies.data.PublishRate;
|
94 | 88 | import org.apache.pulsar.common.policies.data.RetentionPolicies;
|
95 |
| -import org.apache.pulsar.common.policies.data.SchemaCompatibilityStrategy; |
96 | 89 | import org.apache.pulsar.common.policies.data.TenantInfo;
|
97 | 90 | import org.apache.pulsar.common.policies.data.TopicStats;
|
98 | 91 | import org.apache.pulsar.common.policies.data.impl.AutoTopicCreationOverrideImpl;
|
99 |
| -import org.apache.pulsar.common.schema.SchemaInfo; |
100 |
| -import org.apache.pulsar.common.schema.SchemaType; |
101 | 92 | import org.apache.pulsar.common.util.FutureUtil;
|
102 | 93 | import org.apache.pulsar.common.util.collections.ConcurrentOpenHashMap;
|
103 | 94 | import org.awaitility.Awaitility;
|
104 | 95 | import org.awaitility.reflect.WhiteboxImpl;
|
105 | 96 | import org.glassfish.jersey.client.JerseyClient;
|
106 | 97 | import org.glassfish.jersey.client.JerseyClientBuilder;
|
107 |
| -import org.junit.Assert; |
| 98 | +import org.testng.Assert; |
108 | 99 | import org.mockito.Mockito;
|
109 | 100 | import org.testng.annotations.AfterClass;
|
110 | 101 | import org.testng.annotations.BeforeClass;
|
|
0 commit comments