[fix][txn] fix test

hrzzzz · Sep 26, 2023 · 1174b57 · 1174b57
1 parent a97446e
commit 1174b57
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/TransactionEndToEndTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/TransactionEndToEndTest.java
@@ -259,9 +259,11 @@ private void testMsgsInPendingAckStateWouldNotGetTheConsumerStuck() throws Excep
         final String topicName = NAMESPACE1 + "/testMsgsInPendingAckStateWouldNotGetTheConsumerStuck";
         final String subscription = "test";
 
+        @Cleanup
         Producer<Integer> producer = pulsarClient.newProducer(Schema.INT32)
                 .topic(topicName)
                 .create();
+        @Cleanup
         Consumer<Integer> consumer = pulsarClient.newConsumer(Schema.INT32)
                 .topic(topicName)
                 .subscriptionName(subscription)
@@ -294,6 +296,7 @@ private void testMsgsInPendingAckStateWouldNotGetTheConsumerStuck() throws Excep
 
         // close and re-create consumer
         consumer.close();
+        @Cleanup
         Consumer<Integer> consumer2 = pulsarClient.newConsumer(Schema.INT32)
                 .topic(topicName)
                 .receiverQueueSize(numStep3Receive)