From 118f7be5aa99d5c784fe5e0489df6927c1791d96 Mon Sep 17 00:00:00 2001
From: Chris Bono <chris.bono@gmail.com>
Date: Tue, 7 May 2024 09:20:58 -0500
Subject: [PATCH] Disable flaky ReactivePulsarListenerTombstoneTests

See #561
---
 .../reactive/listener/ReactivePulsarListenerTombstoneTests.java | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/spring-pulsar-reactive/src/test/java/org/springframework/pulsar/reactive/listener/ReactivePulsarListenerTombstoneTests.java b/spring-pulsar-reactive/src/test/java/org/springframework/pulsar/reactive/listener/ReactivePulsarListenerTombstoneTests.java
index 80497c9c..db8829e6 100644
--- a/spring-pulsar-reactive/src/test/java/org/springframework/pulsar/reactive/listener/ReactivePulsarListenerTombstoneTests.java
+++ b/spring-pulsar-reactive/src/test/java/org/springframework/pulsar/reactive/listener/ReactivePulsarListenerTombstoneTests.java
@@ -29,6 +29,7 @@ import org.apache.pulsar.client.api.PulsarClientException;
 import org.apache.pulsar.client.api.Schema;
 import org.apache.pulsar.common.schema.SchemaType;
 import org.apache.pulsar.reactive.client.api.MessageResult;
+import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Nested;
 import org.junit.jupiter.api.Test;
 
@@ -237,6 +238,7 @@ class ReactivePulsarListenerTombstoneTests extends ReactivePulsarListenerTestsBa
 		static List<ReceivedMessage<Foo>> receivedMessagesWithoutHeaders = new ArrayList<>();
 
 		@Test
+		@Disabled("Flaky -> see https://github.com/spring-projects/spring-pulsar/issues/561")
 		void shouldReceiveMessagesWithTombstone() throws Exception {
 			var pulsarProducerFactory = new DefaultPulsarProducerFactory<Foo>(pulsarClient);
 			var fooPulsarTemplate = new PulsarTemplate<>(pulsarProducerFactory);