From 4cc08b218558ed2aa353a2ad0ceb3ea1edb1dc11 Mon Sep 17 00:00:00 2001 From: thcai Date: Tue, 27 Aug 2024 17:08:24 +0200 Subject: [PATCH] test3 --- .../ns4kafka/integration/SchemaIntegrationTest.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/src/test/java/com/michelin/ns4kafka/integration/SchemaIntegrationTest.java b/src/test/java/com/michelin/ns4kafka/integration/SchemaIntegrationTest.java index aa63a390..821ae416 100644 --- a/src/test/java/com/michelin/ns4kafka/integration/SchemaIntegrationTest.java +++ b/src/test/java/com/michelin/ns4kafka/integration/SchemaIntegrationTest.java @@ -850,13 +850,16 @@ void shouldDeleteSchema() { .build(); // Register V4 schema - ns4KafkaClient + var createSchemaResponse = ns4KafkaClient .toBlocking() .exchange(HttpRequest .create(HttpMethod.POST, "/api/namespaces/ns1/schemas") .bearerAuth(token) .body(schemaV4), Schema.class); + // Expects a new version + assertEquals("changed", createSchemaResponse.header("X-Ns4kafka-Result")); + // Delete latest schema version var deleteLatestVersionResponse = ns4KafkaClient .toBlocking() @@ -866,7 +869,7 @@ void shouldDeleteSchema() { assertEquals(HttpStatus.NO_CONTENT, deleteLatestVersionResponse.getStatus()); - // Get all schemas + /*// Get all schemas var getSchemaAfterLatestVersionDeletionResponse = ns4KafkaClient .toBlocking() .exchange(HttpRequest @@ -914,6 +917,6 @@ void shouldDeleteSchema() { .bearerAuth(token), Schema.class); // Expects no returned schema - assertTrue(getSchemaAfterAllVersionsDeletionResponse.getBody().isEmpty()); + assertTrue(getSchemaAfterAllVersionsDeletionResponse.getBody().isEmpty());*/ } }