Skip to content

Commit 7977bf3

Browse files
committed
Remove flaky transaction tests
Signed-off-by: onobc <[email protected]>
1 parent 996968e commit 7977bf3

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

spring-pulsar/src/test/java/org/springframework/pulsar/listener/DefaultPulsarMessageListenerContainerTxnTests.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -44,6 +44,7 @@
4444
import org.junit.jupiter.api.AfterEach;
4545
import org.junit.jupiter.api.BeforeAll;
4646
import org.junit.jupiter.api.BeforeEach;
47+
import org.junit.jupiter.api.Disabled;
4748
import org.junit.jupiter.api.Test;
4849
import org.testcontainers.containers.PulsarContainer;
4950
import org.testcontainers.junit.jupiter.Testcontainers;
@@ -252,11 +253,13 @@ void recordListenerWithBatchAckNotSupported() {
252253
.withMessage("Transactional record listeners can not use batch ack mode");
253254
}
254255

256+
@Disabled("Flaky test see spring-pulsar/issues/1294")
255257
@Test
256258
void batchListenerUsesBatchAckWhenSharedSub() throws Exception {
257259
batchListenerUsesProperBatchAckForSubscriptionType("batch-lstr-batch-ack", SubscriptionType.Shared);
258260
}
259261

262+
@Disabled("Flaky test see spring-pulsar/issues/1294")
260263
@Test
261264
void batchListenerUsesCumulativeAckWhenNotSharedSub() throws Exception {
262265
batchListenerUsesProperBatchAckForSubscriptionType("batch-lstr-cumltv-ack", SubscriptionType.Exclusive);

0 commit comments

Comments
 (0)