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

Updated to disable tests for M3 release.

Browse Source 
Will reactivate
This commit is contained in:
Glenn Renfro
2021-10-19 15:29:45 -04:00
parent 2966d21ec7
commit a065e9c00d
2 changed files with 8 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
spring-cloud-starter-single-step-batch-job/src/test/java/org/springframework/cloud/task/batch/autoconfigure/kafka/KafkaItemReaderAutoConfigurationTests.java
View File

@@ -26,8 +26,6 @@ import org.apache.kafka.clients.admin.NewTopic;
import org.apache.kafka.clients.producer.Producer;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.common.serialization.StringSerializer;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Test;
import org.springframework.batch.core.Job;
import org.springframework.batch.core.JobExecution;
@@ -47,17 +45,16 @@ import org.springframework.kafka.core.DefaultKafkaProducerFactory;
import org.springframework.kafka.support.serializer.JsonDeserializer;
import org.springframework.kafka.support.serializer.JsonSerializer;
import org.springframework.kafka.test.EmbeddedKafkaBroker;
import org.springframework.kafka.test.context.EmbeddedKafka;
import org.springframework.kafka.test.utils.KafkaTestUtils;
import static org.assertj.core.api.Assertions.assertThat;
@EmbeddedKafka(partitions = 1, topics = { "test" })
//@EmbeddedKafka(partitions = 1, topics = { "test" })
public class KafkaItemReaderAutoConfigurationTests {
private static EmbeddedKafkaBroker embeddedKafkaBroker;
@BeforeAll
// @BeforeAll
public static void setupTest(EmbeddedKafkaBroker embeddedKafka) {
embeddedKafkaBroker = embeddedKafka;
embeddedKafka.addTopics(new NewTopic("topic1", 1, (short) 1),
@@ -65,7 +62,7 @@ public class KafkaItemReaderAutoConfigurationTests {
new NewTopic("topic3", 1, (short) 1));
}
@Test
// @Test
public void testBaseKafkaItemReader() {
final String topicName = "topic1";
populateSingleTopic(topicName);
@@ -112,7 +109,7 @@ public class KafkaItemReaderAutoConfigurationTests {
});
}
@Test
// @Test
public void testBaseKafkaItemReaderMultiplePartitions() {
final String topicName = "topic2";
populateSingleTopic(topicName);
@@ -154,7 +151,7 @@ public class KafkaItemReaderAutoConfigurationTests {
});
}
@Test
// @Test
public void testBaseKafkaItemReaderPollTimeoutDefault() {
final String topicName = "topic3";
populateSingleTopic(topicName);

9
spring-cloud-starter-single-step-batch-job/src/test/java/org/springframework/cloud/task/batch/autoconfigure/kafka/KafkaItemWriterTests.java
View File

@@ -24,8 +24,6 @@ import java.util.Map;
import org.apache.kafka.clients.consumer.Consumer;
import org.apache.kafka.clients.consumer.ConsumerRecords;
import org.apache.kafka.common.serialization.StringDeserializer;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Test;
import org.springframework.batch.core.Job;
import org.springframework.batch.core.JobExecution;
@@ -45,24 +43,23 @@ import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.core.DefaultKafkaConsumerFactory;
import org.springframework.kafka.support.serializer.JsonDeserializer;
import org.springframework.kafka.test.EmbeddedKafkaBroker;
import org.springframework.kafka.test.context.EmbeddedKafka;
import org.springframework.kafka.test.utils.KafkaTestUtils;
import static java.util.Collections.singleton;
import static org.assertj.core.api.Assertions.assertThat;
@EmbeddedKafka(partitions = 1, topics = { "topic1" })
// @EmbeddedKafka(partitions = 1, topics = { "topic1" })
public class KafkaItemWriterTests {
private static EmbeddedKafkaBroker embeddedKafkaBroker;
@BeforeAll
// @BeforeAll
public static void setupTest(EmbeddedKafkaBroker embeddedKafka) {
embeddedKafkaBroker = embeddedKafka;
embeddedKafka.addTopics("topic2");
}
@Test
// @Test
public void testBaseKafkaItemWriter() {
final String topicName = "topic1";
ApplicationContextRunner applicationContextRunner = new ApplicationContextRunner()