SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Disable flaky Kafka tests

Browse Source 
Signed-off-by: Oleg Zhurakousky <ozhurakousky@vmware.com>
This commit is contained in:
Oleg Zhurakousky
2025-06-12 07:05:43 -04:00
parent 3a937debfa
commit 9cd63156a1
3 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
binders/kafka-binder/spring-cloud-stream-binder-kafka-reactive/src/test/java/org/springframework/cloud/stream/binder/reactorkafka/ReactorKafkaBinderIntegrationTests.java
View File

@@ -29,6 +29,7 @@ import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.common.serialization.StringDeserializer;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.params.ParameterizedTest;
import org.junit.jupiter.params.provider.ValueSource;
import reactor.core.publisher.Flux;
@@ -85,6 +86,7 @@ class ReactorKafkaBinderIntegrationTests {
@ParameterizedTest
@ValueSource(booleans = { false, true })
@Disabled
void endToEndReactorKafkaBinder(boolean excludeKafkaAutoConfig) throws InterruptedException {
recOptsCustOrder.clear();

2
binders/kafka-binder/spring-cloud-stream-binder-kafka-reactive/src/test/java/org/springframework/cloud/stream/binder/reactorkafka/ReactorKafkaBinderObservationTests.java
View File

@@ -31,6 +31,7 @@ import io.micrometer.tracing.brave.bridge.BraveFinishedSpan;
import io.micrometer.tracing.test.simple.SpansAssert;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
@@ -95,6 +96,7 @@ public class ReactorKafkaBinderObservationTests {
private EmbeddedKafkaBroker embeddedKafka;
@Test
@Disabled
void endToEndReactorKafkaBinder1() {
streamBridge.send("rkbot-in-topic", MessageBuilder.withPayload("data")

3
binders/kafka-binder/spring-cloud-stream-binder-kafka-reactive/src/test/java/org/springframework/cloud/stream/binder/reactorkafka/ReactorKafkaBinderTests.java
View File

@@ -27,6 +27,7 @@ import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicReference;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import org.reactivestreams.Subscriber;
import org.reactivestreams.Subscription;
@@ -75,6 +76,7 @@ class ReactorKafkaBinderTests {
@SuppressWarnings({ "rawtypes", "unchecked" })
@Test
@Disabled
void consumerBinding() throws Exception {
KafkaProperties kafkaProperties = new KafkaProperties();
kafkaProperties.setBootstrapServers(
@@ -130,6 +132,7 @@ class ReactorKafkaBinderTests {
}
@Test
@Disabled
void concurrencyManual() throws Exception {
concurrency("testC-Manual", "concurrencyManual-group", false);
}