From 67887e85ed0ccfa45f449b22435e3337f1efe6c6 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Mon, 7 Apr 2025 19:42:59 +0200 Subject: [PATCH] ROT: Verhalten beim Abrufen von einer nicht existierenden Partition definiert --- src/test/java/de/juplo/kafka/ApplicationTests.java | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java index 0f78ea7..942bf69 100644 --- a/src/test/java/de/juplo/kafka/ApplicationTests.java +++ b/src/test/java/de/juplo/kafka/ApplicationTests.java @@ -10,6 +10,8 @@ import org.junit.jupiter.api.AfterEach; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.DisplayName; import org.junit.jupiter.api.Test; +import org.junit.jupiter.params.ParameterizedTest; +import org.junit.jupiter.params.provider.ValueSource; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.boot.test.context.SpringBootTest; @@ -74,6 +76,15 @@ public class ApplicationTests assertThat(response.getStatusCode()).isEqualTo(HttpStatusCode.valueOf(HttpStatus.NOT_FOUND.value())); } + @DisplayName("Non-existent partition") + @ParameterizedTest(name = "partition: {0}") + @ValueSource(ints = { -1, NUM_PARTITIONS, 66 }) + void testNonExistentPartition(int partition) + { + ResponseEntity response = restTemplate.getForEntity("/{partition}/0", String.class, partition); + assertThat(response.getStatusCode()).isEqualTo(HttpStatusCode.valueOf(HttpStatus.NOT_FOUND.value())); + } + static final String TOPIC = "ExampleConsumerTest_TEST"; static final int NUM_PARTITIONS = 7; -- 2.20.1