diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/NegativeAcksTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/NegativeAcksTest.java index 15321252fa2e2..71de1ff544ec9 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/NegativeAcksTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/NegativeAcksTest.java @@ -367,7 +367,7 @@ public void testNegativeAcksWithBatchAckEnabled() throws Exception { @Test public void testFailoverConsumerBatchCumulateAck() throws Exception { - final String topic = "my-topic"; + final String topic = BrokerTestUtil.newUniqueName("my-topic"); admin.topics().createPartitionedTopic(topic, 2); @Cleanup