diff --git a/src/test/java/com/michelin/ns4kafka/integration/SchemaIntegrationTest.java b/src/test/java/com/michelin/ns4kafka/integration/SchemaIntegrationTest.java index cc5d11ef..15cec076 100644 --- a/src/test/java/com/michelin/ns4kafka/integration/SchemaIntegrationTest.java +++ b/src/test/java/com/michelin/ns4kafka/integration/SchemaIntegrationTest.java @@ -913,6 +913,16 @@ void shouldDeleteSchema() { .create(HttpMethod.GET, "/api/namespaces/ns1/schemas/ns1-subject4-value") .bearerAuth(token), Schema.class); - assertEquals(HttpStatus.NOT_FOUND, getSchemaAfterAllVersionsDeletionResponse.getStatus()); + // Get all schemas + var getResponseEmpty = ns4KafkaClient + .toBlocking() + .exchange(HttpRequest + .create(HttpMethod.GET, "/api/namespaces/ns1/schemas") + .bearerAuth(token), Argument.listOf(SchemaList.class)); + + assertTrue(getResponseEmpty.getBody().isPresent()); + assertTrue(getResponseEmpty.getBody().get() + .stream() + .noneMatch(schemaList -> schemaList.getMetadata().getName().equals("ns1-subject4-value"))); } }