iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

JAVA-29164 | fixing failing test (#15401)

Browse Source
This commit is contained in:
Gaetano Piazzolla 2023-12-11 18:54:21 +01:00 committed by GitHub
parent ec8fe08bb8
commit 7f894fe513
4 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
apache-kafka/pom.xml
View File

@ -181,6 +181,7 @@
</build> </build>
<properties> <properties>
<jackson.version>2.13.4</jackson.version>
<kafka.version>3.4.0</kafka.version> <kafka.version>3.4.0</kafka.version>
<testcontainers-kafka.version>1.19.3</testcontainers-kafka.version> <testcontainers-kafka.version>1.19.3</testcontainers-kafka.version>
<testcontainers-jupiter.version>1.15.3</testcontainers-jupiter.version> <testcontainers-jupiter.version>1.15.3</testcontainers-jupiter.version>

2
apache-kafka/src/test/java/com/baeldung/flink/BackupCreatorIntegrationTest.java → apache-kafka/src/test/java/com/baeldung/flink/BackupCreatorUnitTest.java
View File

@ -29,7 +29,7 @@ import java.util.List;
import static org.junit.Assert.assertArrayEquals; import static org.junit.Assert.assertArrayEquals;
import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertEquals;
public class BackupCreatorIntegrationTest { public class BackupCreatorUnitTest {
public static ObjectMapper mapper; public static ObjectMapper mapper;
@Before @Before

2
apache-kafka/src/test/java/com/baeldung/flink/WordCapitalizerIntegrationTest.java → apache-kafka/src/test/java/com/baeldung/flink/WordCapitalizerUnitTest.java
View File

@ -10,7 +10,7 @@ import java.util.Arrays;
import java.util.List; import java.util.List;
import java.util.stream.Collectors; import java.util.stream.Collectors;
public class WordCapitalizerIntegrationTest { public class WordCapitalizerUnitTest {
@Test @Test
public void givenDataSet_whenExecuteWordCapitalizer_thenReturnCapitalizedWords() throws Exception { public void givenDataSet_whenExecuteWordCapitalizer_thenReturnCapitalizedWords() throws Exception {

7
apache-kafka/src/test/java/com/baeldung/kafkastreams/KafkaStreamsLiveTest.java
View File

@ -21,8 +21,7 @@ import org.junit.Ignore;
import org.junit.Test; import org.junit.Test;
public class KafkaStreamsLiveTest { public class KafkaStreamsLiveTest {
private String bootstrapServers = "localhost:9092"; private final String bootstrapServers = "localhost:9092";
private Path stateDirectory;
@Test @Test
@Ignore("it needs to have kafka broker running on local") @Ignore("it needs to have kafka broker running on local")
@ -44,8 +43,8 @@ public class KafkaStreamsLiveTest {
// Use a temporary directory for storing state, which will be automatically removed after the test. // Use a temporary directory for storing state, which will be automatically removed after the test.
try { try {
this.stateDirectory = Files.createTempDirectory("kafka-streams"); Path stateDirectory = Files.createTempDirectory("kafka-streams");
streamsConfiguration.put(StreamsConfig.STATE_DIR_CONFIG, this.stateDirectory.toAbsolutePath() streamsConfiguration.put(StreamsConfig.STATE_DIR_CONFIG, stateDirectory.toAbsolutePath()
.toString()); .toString());
} catch (final IOException e) { } catch (final IOException e) {
throw new UncheckedIOException("Cannot create temporary directory", e); throw new UncheckedIOException("Cannot create temporary directory", e);