diff --git a/kafka-ui-api/src/test/java/com/provectus/kafka/ui/KafkaConsumerTests.java b/kafka-ui-api/src/test/java/com/provectus/kafka/ui/KafkaConsumerTests.java index bb9200a2f0..7fff3fa6dc 100644 --- a/kafka-ui-api/src/test/java/com/provectus/kafka/ui/KafkaConsumerTests.java +++ b/kafka-ui-api/src/test/java/com/provectus/kafka/ui/KafkaConsumerTests.java @@ -65,4 +65,15 @@ public class KafkaConsumerTests extends AbstractBaseTest { .expectBodyList(TopicMessage.class) .hasSize(0); } + + @Test + public void shouldReturn404ForNonExistingTopic() { + var topicName = UUID.randomUUID().toString(); + + webTestClient.delete() + .uri("/api/clusters/{clusterName}/topics/{topicName}/messages", LOCAL, topicName) + .exchange() + .expectStatus() + .isNotFound(); + } } diff --git a/kafka-ui-contract/src/main/resources/swagger/kafka-ui-api.yaml b/kafka-ui-contract/src/main/resources/swagger/kafka-ui-api.yaml index 0a1dfe6e78..036c249bcc 100644 --- a/kafka-ui-contract/src/main/resources/swagger/kafka-ui-api.yaml +++ b/kafka-ui-contract/src/main/resources/swagger/kafka-ui-api.yaml @@ -328,6 +328,8 @@ paths: responses: 200: description: OK + 404: + description: Not found /api/clusters/{clusterName}/consumer-groups/{id}: get: